C#多线程处理多个队列数据的方法

第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