c#实现生产者消费者

做操作系统课设的时候使用的基本代码。

  2. using System;
  3. using System.Collections.Generic;
  4. using System.Text;
  5. using System.Collections;
  6. using System.Threading;
  7. namespace ConsoleApplication4
  8. {
  9.     class Program
  10.     {
  11.         ArrayList container = new ArrayList();
  12.         Producer producer = null;
  13.         Consumer consumer = null;
  14.         static void Main(string[] args)
  15.         {
  16.             Program p = new Program();
  17.             Thread t1 = new Thread(new ThreadStart(p.ThreadProduct));
  18.             Thread t2 = new Thread(new ThreadStart(p.ThreadConsumption));
  19.             t1.Start();
  20.             t2.Start();
  21.             Console.Read();
  22.         }
  23.         public void ThreadProduct()
  24.         {
  25.             producer = new Producer(this.container);
  26.             lock (this)
  27.             {
  28.                 for (int i = 1; i <= 8; i++)
  29.                 {
  30.                     if (this.container.Count == 0)
  31.                     {
  32.                         producer.Product(i + "");
  33.                         Monitor.Pulse(this);
  34.                     }
  35.                     Monitor.Wait(this);
  36.                 }
  37.             }
  38.         }
  39.         public void ThreadConsumption()
  40.         {
  41.             consumer = new Consumer(this.container);
  42.             lock (this)
  43.             {
  44.                 while (true)
  45.                 {
  46.                     if (this.container.Count != 0)
  47.                     {
  48.                         consumer.Consumption();
  49.                         Monitor.Pulse(this);
  50.                     }
  51.                     Monitor.Wait(this);
  52.                 }
  53.             }
  54.         }
  55.     }
  56.     public class Consumer
  57.     {
  58.         ArrayList container = null;
  59.         public Consumer(ArrayList container)
  60.         {
  61.             this.container = container;
  62.         }
  63.         public void Consumption()
  64.         {
  65.             Goods goods = (Goods)this.container[0];
  66.             Console.WriteLine("消费了物品：" + goods.ToString());
  67.             this.container.RemoveAt(0);
  68.         }
  69.     }
  70.     public class Producer
  71.     {
  72.         ArrayList container = null;
  73.         public Producer(ArrayList container)
  74.         {
  75.             this.container = container;
  76.         }
  77.         public void Product(string name)
  78.         {
  79.             Goods goods = new Goods();
  80.             goods.Name = name;
  81.             this.container.Add(goods);
  82.             Console.WriteLine("生产了物品：" + goods.ToString());
  83.         }
  84.     }
  85.     public class Goods
  86.     {
  87.         private string name;
  88.         public string Name
  89.         {
  90.             get { return name; }
  91.             set { name = value; }
  92.         }
  93.         public override string ToString()
  94.         {
  95.             return "物品名称：" + name;
  96.         }
  97.     }
  98. }

 

版权声明：本文为wk360833257原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。