using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;namespace ThreadTest
{class Program{static void Main(string[] args){new ProductAndCostTester();}}/// <summary>/// 生产消费模型/// </summary>public class ProductAndCostTester{/// <summary>/// 生产线1线程/// </summary>private Thread _producterThread1;/// <summary>/// 生产线2线程/// </summary>private Thread _producterThread2;/// <summary>/// 消费线线程/// </summary>private Thread _costerThread;/// <summary>/// 产品列表/// </summary>private List<int> _goodList;/// <summary>/// ManualResetEvent实例/// </summary>private ManualResetEvent _mre;public ProductAndCostTester(){_goodList = new List<int>();_mre = new ManualResetEvent(false);//false初始化状态为无信号，将使WaitOne阻塞
_producterThread1 = new Thread(Product1);_producterThread1.Name = "Productor1";_producterThread1.Start();_producterThread2 = new Thread(Product2);_producterThread2.Name = "Productor2";_producterThread2.Start();_costerThread = new Thread(Cost);_costerThread.Name = "Costor";_costerThread.Start();}/// <summary>/// 生产线1/// </summary>void Product1(){while (true){Console.WriteLine(Thread.CurrentThread.Name + ":" + DateTime.Now.ToString("HH:mm:ss"));for (int i = 0; i < 3; i++){_goodList.Add(1);}_mre.Set();//表示有信号了，通知WaitOne不再阻塞
Thread.Sleep(8000);}}/// <summary>/// 生产线2/// </summary>void Product2(){while (true){Console.WriteLine(Thread.CurrentThread.Name + ":" + DateTime.Now.ToString("HH:mm:ss"));for (int i = 0; i < 6; i++){_goodList.Add(1);}_mre.Set();//表示有信号了，通知WaitOne不再阻塞
Thread.Sleep(10000);}}/// <summary>/// 消费线/// </summary>void Cost(){while (true){if (_goodList.Count > 0){Console.WriteLine("Cost " + _goodList.Count + " at " + DateTime.Now.ToString("HH:mm:ss"));_goodList.Clear();_mre.Reset();//重置为无信号了，使WaitOne可以再次阻塞
                }else{Console.WriteLine("No cost at " + DateTime.Now.ToString("HH:mm:ss"));_mre.WaitOne();//如果没有可消费的产品，即无信号，则会阻塞
                }}}}
}