多线程之生产者---消费者模式

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace ConsoleApplication1
{
    class EatAppleSmp
    {
        public EatAppleSmp()
        {
            Thread mother, father, lada, laoer, laosan;
            Dish dish = new Dish(this, 30);
            productor mother1 = new productor("mother", dish);
            productor father1 = new productor("father", dish);
            customer lada1 = new customer("laoda", dish);
            customer laoer1 = new customer("laoer", dish);
            customer laosan1 = new customer("laosan", dish);
            mother=new Thread(new ThreadStart(mother1.run));
            father = new Thread(new ThreadStart(father1.run));
            lada = new Thread(new ThreadStart(lada1.run));
            laoer = new Thread(new ThreadStart(laoer1.run));
            laosan = new Thread(new ThreadStart(laosan1.run));
            mother.Priority = ThreadPriority.Highest;
            father.Priority = ThreadPriority.Normal;
            lada.Priority = ThreadPriority.Lowest;
            laoer.Priority = ThreadPriority.Normal;
            laosan.Priority = ThreadPriority.Highest;
            mother.Start();
            father.Start();
            lada.Start();
            laoer.Start();
            laosan.Start();
        }
        
    }
    class productor
    {
        private Dish dish;
        private string name;
        public productor(string name,Dish dish)
        {
            this.dish = dish;
            this.name = name;
        }
        public void run()
        {
            while (true)
            {
                dish.put(this.name);
                Thread.Sleep(600);
            }
            
        }
    }
    class customer
    {
        private Dish dish;
        private string name;
        public customer(string name, Dish dish)
        {
            this.dish = dish;
            this.name = name;
        }
        public void run()
        {
            while (true)
            {
                dish.get(this.name);
            }
        }
    }
    class Dish
    {
        int f = 5;//可放苹果的数量
        int total;//总共的苹果个数
        int n = 0;
        int j = 0;
        EatAppleSmp app;
        public Dish(EatAppleSmp tst, int total_apple)
        {
            this.total = total_apple;
            this.app = tst;

        }
        public void put(string name)
        {
            if (n > total)
                if (Thread.CurrentThread.IsAlive)
                    Thread.CurrentThread.Abort();
            lock (this)
            {
                while (f == 0)
                {
                    try
                    {
                        Console.WriteLine(name + "正在放苹果......");
                        Monitor.Wait(this);
                    }
                    catch(Exception e) { }
                }
                f--;//苹果放一个
                Console.WriteLine(name+"放了一个苹果");
                n++;
                Monitor.PulseAll(this);
            }
        }
        public void get(string name)
        {
            if (j >= total)
            {
                if (Thread.CurrentThread.IsAlive)
                    Thread.CurrentThread.Abort();
            }
            lock (this)
            {
                while (f == 5)
                {
                    Console.WriteLine(name + "等待取苹果......");
                    Monitor.Wait(this);
                }
                f++;//苹果吃一个
                Console.WriteLine(name + "吃了一个苹果");
                j++;
               
                Monitor.PulseAll(this);
                
            }
        }
    }
    class Program
    {
        static void Main(string[] args)
        {
            EatAppleSmp test = new EatAppleSmp();
            Console.ReadKey();
        }
    }
}

利用lock解决多线程同步问题。题目：爸爸妈妈削苹果，三个孩子吃，盘子可装5个苹果。用到知识点monitor.wait()与monitor.plusAll();

monitor.wait()释放锁直到重新获取该对象。plusall(),告知其他线程资源已释放。