黑马程序员技术交流社区

标题: 多线程的多生产多消费的解决方法 [打印本页]
作者: 王春蕾    时间: 2014-4-15 14:25
标题: 多线程的多生产多消费的解决方法
  1. /*
  2. 多生产者和多消费者   等待唤醒机制
  3. */
  4. class ThreadDemo_Producer_Consumer2
  5. {
  6.         public static void main(String[] args)
  7.         {
  8.                 Resource r=new Resource();
  9.                 Producer pro=new Producer(r);
  10.                 Consumer con=new Consumer(r);
  11.                 Thread t1=new Thread(pro);
  12.                 Thread t2=new Thread(pro);
  13.                 Thread t3=new Thread(con);
  14.                 Thread t4=new Thread(con);
  15.                 t1.start();
  16.                 t2.start();
  17.                 t3.start();
  18.                 t4.start();
  19.         }
  20. }

  22. class Resource
  23. {
  24.         //定义一个商品的名字
  25.         private String name;
  26.         //定义一个商品的编号
  27.         private int count=1;
  28.         //定义标记
  29.         boolean flag=false;
  30.         public synchronized void set(String name)
  31.         {
  32.                 while(flag)
  33.                         try
  34.                         {
  35.                                 wait();
  36.                         }
  37.                         catch (InterruptedException e)
  38.                         {
  39.                         }
  40.                 this.name=name+"---"+count;
  41.                 count++;
  42.                 System.out.println(Thread.currentThread().getName()+"...生产了,"+this.name);
  43.                 //将标记改为true
  44.                 flag=true;
  45.                 notifyAll();
  46.         }
  47.         public synchronized void get()
  48.         {
  49.                 while(!flag)
  50.                         try
  51.                         {
  52.                                 wait();
  53.                         }
  54.                         catch (InterruptedException e)
  55.                         {
  56.                         }
  57.                 System.out.println(Thread.currentThread().getName()+"...消费了.."+this.name);
  58.                 flag=!flag;
  59.                 notifyAll();
  60.         }
  61. }
  62. //定义生产者的任务
  63. class Producer implements Runnable
  64. {
  65.         private Resource r;
  66.         Producer(Resource r)
  67.         {
  68.                 this.r=r;
  69.         }
  70.         public void run()
  71.         {
  72.                 while(true)
  73.                 {
  74.                         r.set("蛋糕");
  75.                 }
  76.         }
  77. }
  78. //定义消费者的任务
  79. class Consumer implements Runnable
  80. {
  81.         private Resource r;
  82.         Consumer(Resource r)
  83.         {
  84.                 this.r=r;
  85.         }
  86.         public void run()
  87.         {
  88.                 while(true)
  89.                 {
  90.                         r.get();
  91.                 }
  92.         }
  93. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2