黑马程序员技术交流社区

标题: 多线程问题 [打印本页]
作者: 雨下阳光    时间: 2014-9-27 22:21
标题: 多线程问题
  1. import java.util.concurrent.locks.*;

  3. /*
  4. * 生产者生产烤鸭，消费者消费
  5. * 两个或多个生产者，生产一次就等待消费一次
  6. * 多个消费者，等待生产者生产一次就消费
  7. * 生产到100个就停止生产
  8. */
  9. class Store {
  10.         private boolean flag=true;
  11.         private String name;
  12.         private int count=1;
  13.         Lock lock=new ReentrantLock();//创建一个锁对象
  14.         Condition con=lock.newCondition();//获得监视器对象
  15.         public  void set(String name) {
  16.                 lock.lock();
  17.                 try{               
  18.                         while(flag)
  19.                             try{con.await(); } catch(Exception e) {}
  20.                    this.name=name+count;
  21.                    count++;
  22.                         System.out.println(Thread.currentThread().getName()+":"+"生产者生产"+this.name);
  23.                 flag=false;
  24.                 con.signalAll();       
  25.                 }
  26.                 finally {lock.unlock();}
  27.         }
  28.         public  void out() {
  29.                 lock.lock();
  30.                 try{
  31.                     while(!flag)                        
  32.                         try{con.await();}catch(Exception e) {}               
  33.                         System.out.println(Thread.currentThread().getName()+":"+"消费者消费"+this.name);
  34.                 flag=true;
  35.                 con.signalAll();
  36.                 }
  37.                 finally {lock.unlock();}
  38.     }
  39. }
  40. class Producer implements Runnable {
  41.         Store r;
  42.         Producer(Store r) {
  43.                 this.r=r;
  44.         }
  45.         public void run() {
  46.                 while(true) {
  47.                 r.set("烤鸭");       
  48.                 }
  49.         }
  50. }
  51. class Consumer implements Runnable {
  52.         Store r;
  53. Consumer(Store r) {
  54.         this.r=r;
  55. }
  56. public void run() {
  57.         while(true) {
  58.         r.out();       
  59.         }       
  60.   }
  61. }  
  62. public class ProducerConsumerDemo {

  64.         public static void main(String[] args) {
  65.                 Store r=new Store();
  66.       Producer pro=new Producer(r);
  67.       Consumer con=new Consumer(r);
  68. Thread t1=new Thread(pro);
  69. Thread t2=new Thread(pro);
  70. Thread t3=new Thread(con);
  71. Thread t4=new Thread(con);
  72. t1.start();
  73. t2.start();
  74. t3.start();
  75. t4.start();
  76.         }
  77. }
复制代码

我这个程序与毕老师基本一模一样，为什么结果this.name是null呢？求大神帮忙
作者: 谢建平    时间: 2014-9-28 12:59
while(flag)     还有后面的 flag=true;    生产和消费两对这判断你仔细想下  不对的  不直接给答案了



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