黑马程序员技术交流社区

标题: Java基础--多线程之生产者消费者同步问题 [打印本页]
作者: michael_wlq    时间: 2015-9-11 13:57
标题: Java基础--多线程之生产者消费者同步问题
/**
*        对于多个生产者和消费者,为什么要定义while判断标记?
*        原因：让被唤醒的线程再一次判断标记。
*
*        为什么定义notifyAll()?
*        因为需要唤醒对方线程,只用notify()，容易出现只唤醒本方线程的情况,导致程序中的所有线程都等待。
*/
  1. class Resource
  2. {
  3.         private String name;
  4.         private int count = 1;
  5.         private boolean flag = false;

  7.         public synchronized void set(String name)
  8.         {
  9.                 while(flag)
  10.                         try{
  11.                                 wait();
  12.                         }catch(Exception e){
  13.                                
  14.                         }

  16.                 this.name = name+"--"+count++;

  18.                 System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
  19.                 flag = true;
  20.                 this.notifyAll();
  21.         }

  23.         public synchronized void out()
  24.         {
  25.                 while(!flag)
  26.                         try{
  27.                                 wait();
  28.                         }catch(Exception e){
  29.                                
  30.                         }
  31.                 System.out.println(Thread.currentThread().getName()+"...消费者........."+this.name);
  32.                 flag = false;
  33.                 this.notifyAll();
  34.         }
  35. }

  37. class Producer implements Runnable
  38. {
  39.         private Resource res;
  40.         Producer(Resource res)
  41.         {
  42.                 this.res = res;
  43.         }
  44.         public void run()
  45.         {
  46.                 while(true)
  47.                 {
  48.                         res.set("+商品+");
  49.                 }
  50.         }
  51. }

  53. class Consumer implements Runnable
  54. {
  55.         private Resource res;

  57.         Consumer(Resource res)
  58.         {
  59.                 this.res = res;
  60.         }
  61.         public void run()
  62.         {
  63.                 while(true)
  64.                 {
  65.                         res.out();
  66.                 }
  67.         }
  68. }

  70. class ProducerConsumerDemo
  71. {
  72.         public static void main(String[] args)
  73.         {
  74.                 Resource r = new Resource();

  76.                 Producer pro = new Producer(r);
  77.                 Consumer con = new Consumer(r);

  79.                 Thread t1 = new Thread(pro);
  80.                 Thread t2 = new Thread(pro);
  81.                 Thread t3 = new Thread(con);
  82.                 Thread t4 = new Thread(con);

  84.                 t1.start();
  85.                 t2.start();
  86.                 t3.start();
  87.                 t4.start();

  89.         }
  90. }
复制代码








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