1. 程式人生 > 其它 >.Net 多執行緒,非同步且控制併發數量

.Net 多執行緒,非同步且控制併發數量

場景是批量上傳圖片,所以使用了併發。因為伺服器電腦也是有瓶頸的,且多執行緒也不能無限開。。

所以我在使用多執行緒非同步上傳的同時,同時控制執行緒併發的數量,執行緒數量達到閾值之後,得等待一個成功結束之後,再開啟另一個新的執行緒。。

主要使用:Task.WaitAny() 這個API,傳一個執行緒陣列, 等待其中一個執行完成,只等最快的一個執行完成。。每個執行緒在開啟之前去判斷正在執行的執行緒的數量

控制最大執行緒數量為4。 程式碼:

                //控制併發執行緒的數量
                List<Task> tasks = new List<Task>();
                for (int i = 0; i < 50; i++)
                {
                    int k = i;

                    Console.WriteLine($"執行數量為**{tasks.Count(t => t.Status == TaskStatus.Running)}***");

                    if (tasks.Count(t => t.Status == TaskStatus.Running) > 3)
                    {
                        var runID = tasks.Count(t => t.Status == TaskStatus.Running);
                        Console.WriteLine($"執行數量為**{runID},大於3個了,請稍等***");
                        
                        Task.WaitAny(tasks.ToArray());
                        tasks = tasks.Where(t => t.Status != TaskStatus.RanToCompletion).ToList();
                    }
                    else
                    {
                        var taskItem = Task.Run(() =>
                        {
                            Console.WriteLine($"開啟新執行緒**{k}  ***{Thread.CurrentThread.ManagedThreadId.ToString("00")}");
                            //處理固定的工作
                            Thread.Sleep(2000);
                        });
                        tasks.Add(taskItem);
                      
                    }
                }

    效果:

第二種方法: 利用 Parallel類來操作,通過MaxDegreeOfParallelism引數控制最大額並行數量。

                Task.Run(() =>
                {
                    ParallelOptions parallelOptions = new ParallelOptions();
                    parallelOptions.MaxDegreeOfParallelism = 3;
                    Parallel.For(0, 10, parallelOptions, i => WorkTest("das"));
                });

效果: 達到閾值之後,等待一個執行緒完成之後,才會開啟另一個執行緒。。

這樣就可以控制多執行緒併發數量啦。

分類: .NET