第C#使用泛型隊(duì)列Queue實(shí)現(xiàn)生產(chǎn)消費(fèi)模式如果把生產(chǎn)消費(fèi)想像成自動(dòng)流水生產(chǎn)線的話，生產(chǎn)就是流水線的物料，消費(fèi)就是某種設(shè)備對(duì)物料進(jìn)行加工的行為，流水線就是隊(duì)列。

現(xiàn)在，要寫一個(gè)體現(xiàn)生產(chǎn)消費(fèi)模式的泛型幫助類，比如叫ProducerConsumerT。

該類肯定會(huì)維護(hù)一個(gè)有關(guān)生產(chǎn)、物料的QueueT類型的字段，還存在一個(gè)有關(guān)消費(fèi)、ActionT類型的字段。

在ProducerConsumer類的構(gòu)造函數(shù)中，為ActionT類型的字段賦值，并開啟后臺(tái)有關(guān)消費(fèi)的線程。

ProducerConsumer類肯定存在一個(gè)進(jìn)隊(duì)列的方法，并且要保證在多線程情況下，同一時(shí)間只有一個(gè)生產(chǎn)或物料進(jìn)入隊(duì)列。

ProducerConsumer類還存在一個(gè)有關(guān)消費(fèi)的方法，并且保證在多線程情況下，同一時(shí)間只有一個(gè)生產(chǎn)或物料出列，并消費(fèi)它。

另外，在生產(chǎn)或物料在出隊(duì)列的時(shí)候，可能會(huì)出現(xiàn)隊(duì)列中暫時(shí)沒有生產(chǎn)或物料的情況，這時(shí)候我們希望線程阻塞一下，這需要通過AutoResetEvent實(shí)現(xiàn)。AutoResetEvent的大致原理是：當(dāng)生產(chǎn)或物料進(jìn)入隊(duì)列的時(shí)候需要告訴AutoResetEvent一下，當(dāng)隊(duì)列中暫時(shí)沒有生產(chǎn)或物料的時(shí)候，也需要告訴AutoResetEvent，讓它來阻塞線程。

//有關(guān)生產(chǎn)消費(fèi)的泛型類

publicclassProducerConsumerT

//用來存儲(chǔ)生產(chǎn)者的隊(duì)列

privatereadonlyQueueTqueue=newQueueT

privatereadonlyobjectqueueLocker=newobject();

//消費(fèi)行為

privatereadonlyActionTconsumerAction;

//出列的時(shí)候需要檢查隊(duì)列中是否有元素，如果沒有，需要阻塞

privatereadonlyAutoResetEventqueueWaitHandle=newAutoResetEvent(false);

publicProducerConsumer(ActionTconsumerAction)

if(consumerAction==null)

thrownewArgumentNullException("consumerAction");

this.consumerAction=consumerAction;

//后臺(tái)開啟一個(gè)線程開始消費(fèi)生產(chǎn)者

newThread(this.ConsumeItems){IsBackground=true}.Start();

//進(jìn)列

publicvoidEnqueue(Titem)

//確保同一時(shí)間只有一個(gè)生產(chǎn)者進(jìn)列

lock(queueLocker)

queue.Enqueue(item);

//每次進(jìn)列都要設(shè)置AutoResetEvent事件

this.queueWaitHandle.Set();

//消費(fèi)動(dòng)作

privatevoidConsumeItems()

while(true)

TnextItem=default(T);

//標(biāo)志，確認(rèn)隊(duì)列中的生產(chǎn)者是否存在

booldoesItemExist;

//確保同一時(shí)間只有一個(gè)生產(chǎn)者出列

lock(this.queueLocker)

//先確認(rèn)隊(duì)列中的生產(chǎn)者是否存在

doesItemExist=this.queue.Count

if(doesItemExist)

nextItem=this.queue.Dequeue();

//如果生產(chǎn)者存在，才消費(fèi)生產(chǎn)者

if(doesItemExist)

this.consumerAction(nextItem);

else//否則的話，再等等下一個(gè)隊(duì)列中的生產(chǎn)者

this.queueWaitHandle.WaitOne();

}

客戶端，針對(duì)多線程情形。

classProgram

staticvoidMain(string[]args)

//實(shí)例化一個(gè)int類型的生產(chǎn)消費(fèi)實(shí)例

varproducerConsumer=newProducerConsumerint(i=Console.WriteLine("正在消費(fèi)"+i));

Randomrandom=newRandom();

//開啟進(jìn)隊(duì)列線程

vart1=newThread(()=

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

producerConsumer.Enqueue(i);

Thread.Sleep(random.Next(0,5));

vart2=newThread(()=

for(inti=0;i-100;i--)

producerConsumer.Enqueue(i);

Thread.Sleep(random.Next(0,5));

t1.Start();

t2.Start();

t1.Join();

t2.Join();

T