黑马程序员技术交流社区

标题: 关于多线程————生产者消费者的问题 [打印本页]
作者: 新语新空    时间: 2014-7-29 23:01
标题: 关于多线程————生产者消费者的问题
本帖最后由 新语新空 于 2014-8-7 17:49 编辑

毕老师的视频里讲，如果用if判断flag可能会发生两个生产者（或者消费者）连续执行的情况，因为被唤醒的线程往下执行if语句。为什么换成while以后不是继续往下执行，而是返回判断flag呢？
而事实上，这样好像也可行。我运行过几次，确实没有出现问题。
  1. class ProduceConsumerDemo
  2. {
  3.         public static void main(String[] args)
  4.         {
  5.                 Resource r = new Resource();
  6.                
  7.                 Producer pro = new Producer(r);
  8.                 Consumer con = new Consumer(r);
  9.                
  10.                 Thread t1 = new Thread(pro);
  11.                 Thread t2 = new Thread(pro);
  12.                 Thread t3 = new Thread(con);
  13.                 Thread t4 = new Thread(con);
  14.                 t1.start();
  15.                 t2.start();
  16.                 t3.start();
  17.                 t4.start();
  18.                
  19.                 //new Thread(new Producer(r)).start();
  20.                 //new Thread(new Consumer(r)).start();
  21.         }
  22. }

  24. class Resource
  25. {
  26.         private String name;
  27.         private int count = 1;
  28.         private boolean flag;
  29.         
  30.         public synchronized void set(String name)
  31.         {        
  32.                 while(flag)
  33.                         try
  34.                         {
  35.                                 wait();
  36.                         }
  37.                         catch(Exception e)
  38.                         {
  39.                         
  40.                         }
  41.                 this.name = name+"----"+count++;
  42.                
  43.                 System.out.println(Thread.currentThread().getName()+"生产者"+this.name);
  44.                 flag = true;
  45.                 this.notifyAll();
  46.         }
  47.         
  48.         public synchronized void out()
  49.         {        while(!flag)
  50.                 {
  51.                         try
  52.                         {
  53.                                 wait();
  54.                         }
  55.                         catch(Exception e)
  56.                         {
  57.                         
  58.                         }
  59.                 }
  60.                 System.out.println(Thread.currentThread().getName()+"----消费者-----"+this.name);
  61.                 flag = false;
  62.                 this.notifyAll();
  63.         }
  64. }

  66. class Producer implements Runnable
  67. {
  68.         private Resource r;
  69.         Producer(Resource r)
  70.         {
  71.                 this.r = r;
  72.         }
  73.         
  74.         public void run()
  75.         {
  76.                 while(true)
  77.                 {
  78.                         r.set("商品");
  79.                 }
  80.         }
  81. }

  83. class Consumer implements Runnable
  84. {
  85.         private Resource r;
  86.         Consumer(Resource r)
  87.         {
  88.                 this.r = r;
  89.         }
  90.         
  91.         public void run()
  92.         {
  93.                 while(true)
  94.                 {
  95.                         r.out();
  96.                 }
  97.         }
  98. }
复制代码
作者: 新语新空    时间: 2014-7-29 23:24
在线等，求解答！！！



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