因项目响应过慢，代码优化空间不大，在暂时无法调整系统架构的情况下，只有使用.NET中的TPL解决一些模块耗时过多的问题。但在使用过程中也碰到了一些问题，现在把它写下来，用于备忘。
1. Parallel.ForEach的使用
1 static void Main(string[] args) 2 { 3 //Test(); 4 TestParllel(); 5 Console.ReadLine(); 6 } 7 8 private static void TestParllel() 9 { 10 var list = new List<int>(6000); 11 12 for (int i = 0; i < 6000; i++) 13 { 14 list.Add(i); 15 } 16 Parallel.ForEach(list, (p, state) => { Invoke(p); }); 17 } 18 19 static void Invoke(int i) 20 { 21 Console.WriteLine(Thread.CurrentThread.ManagedThreadId); 22 Thread.Sleep(30000); 23 }
未设置最大线程数的情况下:
a>为设置最大线程的情况下，TPL默认线程数为任务数(系统允许的情况下，设置ThreadPool.SetMaxThreads没有效果)。
b> TPL默认启动5个线程，任务数小于5的话，启动任务数个线程。
c> 如果任务较多,TPL在初始化5个线程后，每隔100毫秒左右新增线程，直到达到最大线程数。如果新增线程的过程中有任务完成，那么就不会新增线程。
缺点：线程数无法控制，容易造成高CPU，系统失去响应。
设置了最大线程数的情况下:
1 private static void TestParllel() 2 { 3 var list = new List<int>(6000); 4 5 for (int i = 0; i < 6000; i++) 6 { 7 list.Add(i); 8 } 9 Parallel.ForEach(list, new ParallelOptions { MaxDegreeOfParallelism = 2}, (p, state) => { Invoke(p); }); 10 }
设置了最大线程数为2
a> 系统运行可控，不会造成高CPU的情况。
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。