第C#多線程處理多個隊列數據的方法多線程(multithreading)，是指從軟件或者硬件上實現多個線程并發執行的技術。具有多線程能力的計算機因有硬件支持而能夠在同一時間執行多于一個線程，進而提升整體處理性能。具有這種能力的系統包括對稱多處理機、多核心處理器以及芯片級多處理或同時多線程處理器。在一個程序中，這些獨立運行的程序片段叫作“線程”(Thread)，利用它編程的概念就叫作“多線程處理”。

隊列(Queue)代表了一個先進先出的對象集合。當您需要對各項進行先進先出的訪問時，則使用隊列。當您在列表中添加一項，稱為入隊，當您從列表中移除一項時，稱為出隊。

比如平常我們在處理定時任務的時候，假設就一臺機器，我們不可能單線程一條一條數據的去跑，這時候就需要提高機器資源的利用率。

下面我們來介紹下，如何實現多線程+隊列以提高并發處理能力。

代碼實現

1、定義線程數threadNum和隊列queues

///summary

///線程總數

////summary

privateintthreadNum=4;

///summary

///總數

////summary

privateinttotalCount=0;

///summary

///已處理

////summary

privateintindex=0;

///summary

///隊列

////summary

privateConcurrentQueueAssetRepaymentqueues=newConcurrentQueueAssetRepayment

2、定義線程列表，往線程添加數據

publicvoidSubDeTransaction()

varlist=newListAssetRepayment

for(inti=0;i1000;i++)

list.Add(newAssetRepayment(){Title=i.ToString()+"---"+Guid.NewGuid().ToString()});

if(list==null||list.Count()==0)

Console.WriteLine("沒有可執行的數據");

return;

totalCount=list.Count;

Console.WriteLine("可執行的數據:"+list.Count()+"條");

foreach(variteminlist)

queues.Enqueue(item);

ListTasktasks=newListTask

for(inti=0;ithreadNum;i++)

vartask=Task.Run(()=

Process();

});

tasks.Add(task);

vartaskList=Task.Factory.ContinueWhenAll(tasks.ToArray(),(ts)=

});

taskList.Wait();

3、對線程數進行限制for(inti=0;ithreadNum;i++)

vartaskList=Task.Factory.ContinueWhenAll(tasks.ToArray(),(ts)=

});

taskList.Wait();

4、從隊列取出數據進行業務處理

privatevoidProcess()

while(true)

varcurrentIndex=Interlocked.Increment(refindex);

AssetRepaymentrepayId=null;

varisExit=queues.TryDequeue(outrepayId);

if(!isExit)

break;

try

Console.WriteLine(repayId.Title);

Console.WriteLine(string.Format("共{0}條當前第{1}條",totalCount,currentIndex));

ca