.net Parallel並行使用注意事項

因項目響應過慢，代碼優化空間不大，在暫時無法調整系統架構的情況下，只有使用.NET中的TPL解決一些模塊耗時過多的問題。但在使用過程中也碰到了一些問題，現在把它寫下來，用於備忘。

 

1. Parallel.ForEach的使用

        static void Main(string[] args)
        {
            //Test();
            TestParllel();
            Console.ReadLine();
        }

        private static void TestParllel()
        {
            var list = new List<int>(6000);

            for (int i = 0; i < 6000; i++)
            {
                list.Add(i);
            }
            Parallel.ForEach(list, (p, state) => { Invoke(p); });
        }

        static void Invoke(int i)
        {
            Console.WriteLine(Thread.CurrentThread.ManagedThreadId);
            Thread.Sleep(30000);
        }

未設置最大線程數的情況下:

a>為設置最大線程的情況下，TPL默認線程數為任務數(系統允許的情況下，設置ThreadPool.SetMaxThreads沒有效果)。

b> TPL默認啟動5個線程，任務數小於5的話，啟動任務數個線程。

c> 如果任務較多,TPL在初始化5個線程后，每隔100毫秒左右新增線程，直到達到最大線程數。如果新增線程的過程中有任務完成，那么就不會新增線程。

缺點：線程數無法控制，容易造成高CPU，系統失去響應。

 

設置了最大線程數的情況下:

        private static void TestParllel()
        {
            var list = new List<int>(6000);

            for (int i = 0; i < 6000; i++)
            {
                list.Add(i);
            }
            Parallel.ForEach(list, new ParallelOptions { MaxDegreeOfParallelism = 2}, (p, state) => { Invoke(p); });
        }

設置了最大線程數為2

a> 系統運行可控，不會造成高CPU的情況。