C#中多線程的並行處理

System.Threading.Tasks,在該命名空間下Task是主類，表示一個類的異步的並發的操作，創建並行代碼的時候不一定要直接使用Task類，在某些情況下可以直接使用Parallel靜態類(System.Threading.Tasks.Parallel)下所提供的方法進行並行開發，而不用底層的Task實例。
並行處理無法保證順序，不需要考慮任務和線程的問題，執行效率加快，當然也不是絕對的，任務的開銷大小對並行任務有影響，如果任務很小，那么由於並行管理的附加開銷（任務分配，調度，同步等成本），可能並行執行並不是優化方案。例如：循環打印10000個數字，for的循環比Parallel.For快

Parallel 類的使用（System.Threading.Tasks）

提供對並行循環和區域的支持。在Parallel下面有三個常用的方法invoke,For和ForEach。

Stopwatch stopWatch = new Stopwatch();

List<int> sourceList = new List<int>();
for (int i = 0; i <= 10000; i++)
{
    sourceList.Add(i);
}

stopWatch.Reset();
stopWatch.Start();
List<int> resultList = new List<int>();
foreach (int option in sourceList) {
    Thread.Sleep(1);
    resultList.Add(option);
}
stopWatch.Stop();
Console.WriteLine("正常運行：" + stopWatch.ElapsedMilliseconds + " ms.");

stopWatch.Reset();
stopWatch.Start();
ConcurrentBag<int> concurrentBagList = new ConcurrentBag<int>();
ParallelOptions options = new ParallelOptions();
options.MaxDegreeOfParallelism = 4;
Parallel.ForEach(sourceList, options, (item) =>
{
    Thread.Sleep(1);
    concurrentBagList.Add(item);
});
stopWatch.Stop();
Console.WriteLine("並行運行：" + stopWatch.ElapsedMilliseconds + " ms.");

上面的例子，如果把Thread.Sleep(1)，去掉可以發現，foreach比Parallel.ForEach快，所以任務的開銷很重要。ConcurrentBag如果換成List可以發現，list中的數據不夠。List集合，數組Int[]，String[] ……，Dictory字典等等。但是這些列表、集合和數組的線程都不是安全的，不能接受並發請求。微軟也提供了線程安全的類Concurrent

Concurrent類（System.Collections）

命名空間提供多個線程安全集合類。當有多個線程並發訪問集合時，應使用這些類代替 System.Collections 和 System.Collections.Generic 命名空間中的對應類型。

BlockingCollection<T> 為實現 IProducerConsumerCollection<T> 的線程安全集合提供阻塞和限制功能。
ConcurrentBag<T> 表示對象的線程安全的無序集合。可以用來替換List<T>
ConcurrentDictionary<TKey, TValue> 表示可由多個線程同時訪問的鍵值對的線程安全集合。Dictionary<TKey, TValue>
ConcurrentQueue<T> 表示線程安全的先進先出 (FIFO) 集合。Queue<T>
ConcurrentStack<T> 表示線程安全的后進先出 (LIFO) 集合。Stack<T>

NuGet中AsyncEnumerator

並行中的多線程

await list.ParallelForEachAsync(async l =>
            {
.......
            });

 

其他的多線程文章

1. C#中await/async閑說

2. .NET中並行開發優化

3. C# Task.Run 和 Task.Factory.StartNew 區別

4. C#中多線程的並行處理

5. C#中多線程中變量研究