c# – Parallel.ForEach不使用所有可用的线程池线程
发布时间：2020-12-15 04:27:07 所属栏目：百科 来源：网络整理
导读：为什么当我运行以下示例时,我是否只让Parallel.ForEach运行的线程数等于我机器上的核心数？ 我以为Parallel.ForEach给你的线程池线程大约有1000个？ int threads1; int threads2; ThreadPool.GetAvailableThreads(out threads1,out threads2); var list = En
|
为什么当我运行以下示例时,我是否只让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个操作同时启动. （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |