下面定義C#生產(chǎn)者和消費者，它們都只有一個方法ThreadRun（），以便在Main（）函數(shù)中提供給線程的ThreadStart代理對象，作為線程的入口。

public class CellProd  
{  
Cell cell; // 被操作的Cell對象  
int quantity = 1; // 生產(chǎn)者生產(chǎn)次數(shù)，初始化為1  
 
public CellProd(Cell box, int request)  
{  
//構造函數(shù)  
cell = box;  
quantity = request;  
}  
public void ThreadRun( )  
{  
for(int looper=1; looper<=quantity; looper++)  
cell.WriteToCell(looper); //生產(chǎn)者向操作對象寫入信息  
}  
}  
 
public class CellCons  
{  
Cell cell;  
int quantity = 1;  
 
public CellCons(Cell box, int request)  
{  
//構造函數(shù)  
cell = box;  
quantity = request;  
}  
public void ThreadRun( )  
{  
int valReturned;  
for(int looper=1; looper<=quantity; looper++)  
valReturned=cell.ReadFromCell( );//消費者從操作對象中讀取信息  
}  
} 

然后在下面這個類MonitorSample的Main()函數(shù)中，我們要做的就是創(chuàng)建兩個線程分別作為C#生產(chǎn)者和消費者，使用CellProd.ThreadRun()方法和CellCons.ThreadRun()方法對同一個Cell對象進行操作

public class MonitorSample  
{  
public static void Main(String[] args)  
{  
int result = 0;   
//一個標志位，如果是0表示程序沒有出錯，如果是1表明有錯誤發(fā)生  
Cell cell = new Cell( );  
 
//下面使用cell初始化CellProd和CellCons兩個類，生產(chǎn)和消費次數(shù)均為20次  
CellProd prod = new CellProd(cell, 20);  
CellCons cons = new CellCons(cell, 20);  
 
Thread producer = new Thread(new ThreadStart(prod.ThreadRun));  
Thread consumer = new Thread(new ThreadStart(cons.ThreadRun));  
//生產(chǎn)者線程和消費者線程都已經(jīng)被創(chuàng)建，但是沒有開始執(zhí)行  
try  
{  
producer.Start( );  
consumer.Start( );  
 
producer.Join( );  
consumer.Join( );  
Console.ReadLine();  
}  
catch (ThreadStateException e)  
{  
//當線程因為所處狀態(tài)的原因而不能執(zhí)行被請求的操作  
Console.WriteLine(e);  
result = 1;  
}  
catch (ThreadInterruptedException e)  
{  
//當線程在等待狀態(tài)的時候中止  
Console.WriteLine(e);  
result = 1;  
}  
//盡管Main()函數(shù)沒有返回值，但下面這條語句可以向父進程返回執(zhí)行結果  
Environment.ExitCode = result;  
}  
} 

在上面的例程中，同步是通過等待Monitor.Pulse（）來完成的。首先生產(chǎn)者生產(chǎn)了一個值，而同一時刻消費者處于等待狀態(tài)，直到收到生產(chǎn)者的“脈沖（Pulse）”通知它生產(chǎn)已經(jīng)完成，此后消費者進入消費狀態(tài)，而生產(chǎn)者開始等待消費者完成操作后將調(diào)用Monitor.Pulese（）發(fā)出的“脈沖 ”。

事實上，這個簡單的例子已經(jīng)幫助我們解決了多線程應用程序中可能出現(xiàn)的大問題，只要領悟了解決線程間沖突的基本方法，很容易把它應用到比較復雜的程序中去。以上介紹C#生產(chǎn)者和消費者。

【編輯推薦】

1. C#結構體的特點淺析
2. 介紹C#窗體拖動事件
3. C#讀取Excel遇到無法讀取的解決方法
4. 概述C#.NET操作XML
5. C#基礎概念學習筆記