微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

c# – Parallel.ForEach不使用所有可用的线程池线程

为什么当我运行以下示例时,我是否只让Parallel.ForEach运行的线程数等于我机器上的核心数?
我以为Parallel.ForEach给你的线程池线程大约有1000个?
int threads1;
            int threads2;

            ThreadPool.GetAvailableThreads(out threads1,out threads2);
            var list = Enumerable.Range(1,200);
            var po = new ParallelOptions
            {
                MaxDegreeOfParallelism = 100
            };

            Parallel.ForEach(list,po,x =>
                {
                    Console.WriteLine("Thread:" + Thread.CurrentThread.ManagedThreadId);
                    Thread.Sleep(1000);
                });

在这里错过了什么吗?

解决方法

Parallel.ForEach使用托管线程池来调度并行操作.线程数由ThreadPool.SetMinThreads和ThreadPool.SetMaxThreads设置.认情况下,最小线程数设置为系统上的处理器数.

为了最小化系统资源的使用,池线程的数量保持尽可能低.当所有池线程忙于执行操作时,调度程序会逐渐生成新线程.

MaxDegreeOfParallelism值通常用于防止Parallel.For同时调度超过指定数量的任务.在长计算的情况下,当没有使用比核心数更多的线程的意义时,它是有用的.

如果通过增加休眠时间Thread.Sleep(100000);来修改代码,您将看到新线程的创建.

如果你调用ThreadPool.SetMinThreads(100,100);在Parallel.ForEach之前,您将看到所有100个操作同时启动.

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐