概述
多執行緒（multithreading），是指從軟體或者硬體上實作多個執行緒並行執行的技術。具有多執行緒能力的電腦因有硬體支持而能夠在同一時間執行多於一個執行緒，進而提升整體處理效能。具有這種能力的系統包括對稱多處理機、多核心處理器以及芯片級多處理或同時多執行緒處理器。在一個程式中，這些獨立執行的程式片段叫作「執行緒」（Thread），利用它編程的概念就叫作「多執行緒處理」。
佇列（Queue）代表了一個先進先出的物件集合。當您需要對各項進行先進先出的存取時，則使用佇列。當您在列表中添加一項，稱為入隊，當您從列表中移除一項時，稱為出隊。
比如平常我們在處理定時任務的時候，假設就一台機器，我們不可能單執行緒一條一條數據的去跑，這時候就需要提高機器資源的利用率。
下面我們來介紹下，如何實作多執行緒+佇列以提高並行處理能力。
程式碼實作
1、定義執行緒數
threadNum
和佇列
queues
///<summary>/// 執行緒總數///</summary>privateint threadNum = 4;///<summary>/// 總數///</summary>privateint totalCount = 0;///<summary>/// 已處理///</summary>privateint index = 0;///<summary>/// 佇列///</summary>private ConcurrentQueue<AssetRepayment> queues = new ConcurrentQueue<AssetRepayment>();
2、定義執行緒列表，往執行緒添加數據
public void SubDeTransaction() {varlist = newList<AssetRepayment>();for (int i = 0; i < 1000; i++) {list.Add(new AssetRepayment() { Title = i.ToString() + "---" + Guid.NewGuid().ToString() }); }if (list == null || list.Count() == 0) { Console.WriteLine("沒有可執行的數據");return; } totalCount = list.Count; Console.WriteLine("可執行的數據:" + list.Count() + "條");foreach (var item in list) { queues.Enqueue(item); }List<Task> tasks = newList<Task>();for (int i = 0; i < threadNum; i++) {var task = Task.Run(() => { Process(); }); tasks.Add(task); }var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) => { }); taskList.Wait(); }
3、對執行緒數進行限制
for
(int i =
0
; i < threadNum; i++)
var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) => { }); taskList.Wait();
4、從佇列取出數據進行業務處理
privatevoidProcess() {while (true) {var currentIndex = Interlocked.Increment(ref index); AssetRepayment repayId = null;var isExit = queues.TryDequeue(out repayId);if (!isExit) {break; }try { Console.WriteLine(repayId.Title); Console.WriteLine(string.Format(" 共{0}條 當前第{1}條", totalCount, currentIndex)); }catch (Exception ex) { Console.WriteLine(ex); } } }
執行測試
程式碼地址
https://gitee.com/conanOpenSource_admin/Example
