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#中多線程中變量研究


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM