C#多线程学习—生产者和消费者

中国IT实验室收集整理

佚名

2008-3-24

保存本文

推荐给好友

收藏本页

欢迎进入.NET社区论坛，与200万技术人员互动交流 >>进入

下面定义生产者类 CellProd 和消费者类 CellCons ，它们都只有一个方法ThreadRun（），以便在Main（）函数中提供给线程的ThreadStart代理对象，作为线程的入口。

public class CellProd
{
　　 Cell cell; // 被操作的Cell对象
　　 int quantity = 1; // 生产者生产次数，初始化为1

　　    public CellProd(Cell box, int request)
　　    {
        //构造函数
        cell = box;
        quantity = request;
　　    }
　　    public void ThreadRun( )
　　    {
        for(int looper=1; looper<=quantity; looper++)
　　　　        cell.WriteToCell(looper); //生产者向操作对象写入信息
　　    }
}

public class CellCons
{
　　 Cell cell;
　　 int quantity = 1;

　　    public CellCons(Cell box, int request)
　　    {
                //构造函数
        cell = box;
        quantity = request;
　　    }
　　    public void ThreadRun( )
　　    {
        int valReturned;
        for(int looper=1; looper<=quantity; looper++)
　　　　        valReturned=cell.ReadFromCell( );//消费者从操作对象中读取信息
　　    }
}

然后在下面这个类MonitorSample的Main()函数中，我们要做的就是创建两个线程分别作为生产者和消费者，使用CellProd.ThreadRun()方法和CellCons.ThreadRun()方法对同一个Cell对象进行操作

public class MonitorSample
{
　　    public static void Main(String[] args)
　　    {
        int result = 0; //一个标志位，如果是0表示程序没有出错，如果是1表明有错误发生
        Cell cell = new Cell( );

        //下面使用cell初始化CellProd和CellCons两个类，生产和消费次数均为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));
        //生产者线程和消费者线程都已经被创建，但是没有开始执行
        try
        {
　　　　    producer.Start( );
　　　　    consumer.Start( );

　　　　    producer.Join( );
　　　　    consumer.Join( );
　　　　    Console.ReadLine();
        }
        catch (ThreadStateException e)
        {
　　　　    //当线程因为所处状态的原因而不能执行被请求的操作
　　　　    Console.WriteLine(e);
　　　　    result = 1;
        }
        catch (ThreadInterruptedException e)
        {
　　　　    //当线程在等待状态的时候中止
　　　　    Console.WriteLine(e);
　　　　    result = 1;
        }
        //尽管Main()函数没有返回值，但下面这条语句可以向父进程返回执行结果
        Environment.ExitCode = result;
　　    }
}