生产者消费者问题（C#）

标签：c#   生产者   消费者   

生产者类：

public class Producer
{

    ArrayList container = null;

    //得到一个容器

    public Producer(ArrayList container)
    {

        this.container = container;

    }

    //定义一个生产物品的方法装入容器

    public void Product(string name)
    {

        //创建一个新物品装入容器

        Goods goods = new Goods();

        goods.Name = name;

        this.container.Add(goods);

        Console.WriteLine("生产了物品：" + goods.ToString());

    }

}

消费者类：

public void Consumption()
    {

        Goods goods = (Goods)this.container[0];

        Console.WriteLine("消费了物品：" + goods.ToString());

        //消费掉容器中的一个物品

        this.container.RemoveAt(0);

    }

}

食物类：

public class Goods
{

    //物品名称

    private string name;

    public string Name
    {

        get { return name; }

        set { name = value; }

    }

    //重写ToString()

    public override string ToString()
    {

        return "物品名称：" + name;

    }

}

主程序：

using System;
using System.Collections.Generic;
using System.Text;
using System.Collections;
using System.Threading;
namespace ConsoleApplication1
{
    class Program
    {
        ArrayList container = new ArrayList();
        Producer producer = null;
        Consumer consumer = null;
        static void Main(string[] args)
        {

            Program p = new Program();

            //创建两个线程并启动

            Thread t1 = new Thread(new ThreadStart(p.ThreadProduct));
            Thread t2 = new Thread(new ThreadStart(p.ThreadConsumption));
            t1.Start();
            //t1.Sleep(1);
            t2.Start();

            Console.Read();

        }

        //定义一个线程方法生产8个物品

        public void ThreadProduct()
        {
            //创建一个生产者
            producer = new Producer(this.container);
            lock (this)  //防止因争夺资源而造成互相等待           {
                for (int i = 1; i                 {

                    //如果容器中没有就进行生产

                    if (this.container.Count == 0)
                    {
                        //调用方法进行生产
                        producer.Product(i + "");
                        //生产好了一个通知消费者消费
                        Monitor.Pulse(this);
                    }

                    //容器中还有物品等待消费者消费后再生
                    Monitor.Wait(this);
                }
            }
        }

        //定义一个线程方法消费生产的物品

        public void ThreadConsumption()
        {

            //创建一个消费者

            consumer = new Consumer(this.container);

            lock (this)//防止因争夺资源而造成互相等待               {

                while (true)
                {

                    //如果容器中有商品就进行消费

                    if (this.container.Count != 0)
                    {

                        //调用方法进行消费

                        consumer.Consumption();

                        Monitor.Pulse(this);

                    }

                    //容器中没有商品通知消费者消费

                    Monitor.Wait(this);

                }

            }

        }
    }
}

生产者消费者问题（C#）

标签：c#   生产者   消费者   

原文地址：http://yw1994.blog.51cto.com/7621136/1569052