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

隊(duì)列(Queue)代表了一個(gè)先進(jìn)先出的對(duì)象集合。當(dāng)您需要對(duì)各項(xiàng)進(jìn)行先進(jìn)先出的訪問時(shí)，則使用隊(duì)列。當(dāng)您在列表中添加一項(xiàng)，稱為入隊(duì)，當(dāng)您從列表中移除一項(xiàng)時(shí)，稱為出隊(duì)。

比如平常我們?cè)谔幚矶〞r(shí)任務(wù)的時(shí)候，假設(shè)就一臺(tái)機(jī)器，我們不可能單線程一條一條數(shù)據(jù)的去跑，這時(shí)候就需要提高機(jī)器資源的利用率。

下面我們來介紹下，如何實(shí)現(xiàn)多線程+隊(duì)列以提高并發(fā)處理能力。

代碼實(shí)現(xiàn)

1、定義線程數(shù)threadNum和隊(duì)列queues

///summary

///線程總數(shù)

////summary

privateintthreadNum=4;

///summary

///總數(shù)

////summary

privateinttotalCount=0;

///summary

///已處理

////summary

privateintindex=0;

///summary

///隊(duì)列

////summary

privateConcurrentQueueAssetRepaymentqueues=newConcurrentQueueAssetRepayment

2、定義線程列表，往線程添加數(shù)據(jù)

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("沒有可執(zhí)行的數(shù)據(jù)");

return;

totalCount=list.Count;

Console.WriteLine("可執(zhí)行的數(shù)據(jù):"+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、對(duì)線程數(shù)進(jìn)行限制for(inti=0;ithreadNum;i++)

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

});

taskList.Wait();

4、從隊(duì)列取出數(shù)據(jù)進(jìn)行業(yè)務(wù)處理

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}條當(dāng)前第{1}條",totalCount,currentIndex));

ca