黑马程序员技术交流社区

标题: 关于生产者和消费者的问题 [打印本页]
作者: 我为你着迷    时间: 2014-7-4 20:28
标题: 关于生产者和消费者的问题
  1. class ProducerConsumerDemo
  2. {
  3.         public static void main(String[] args)
  4.         {
  5.                 Resource r=new Resource();
  6.                
  7.                 Producer pro=new Producer(r);
  8.                
  9.                 Consumer con=new Consumer(r);
  10.                
  11.                 Thread t1=new Thread(pro);
  12.                 Thread t2=new Thread(con);
  13.                 t1.start();
  14.                 t2.start();
  15.         }
  16. }



  20. class Resource
  21. {
  22.         private String name;
  23.         private int count=1;
  24.         private boolean flag=false;
  25.        
  26.         public synchronized void  set(String name)
  27.         {
  28.                 if(flag)
  29.                    try{wait();}catch(Exception e){}
  30.                 this.name=name+"--"+count++;
  31.                
  32.                 System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
  33.                 flag=true;
  34.                 this.notify();
  35.                        
  36.         }       
  37.        
  38.         public void out()
  39.         {
  40.                 if(!flag)
  41.                    try{wait();}catch(Exception e){}
  42.                 System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);
  43.                 flag=false;
  44.                 this.notify();
  45.         }
  46. }


  49. class Producer implements Runnable
  50. {
  51.         private Resource res;
  52.        
  53.         Producer(Resource res)
  54.         {
  55.                 this.res=res;       
  56.         }
  57.         public void run()
  58.         {
  59.                 while(true)
  60.                 {
  61.                         res.set("+商品+");       
  62.                 }
  63.   }
  64.        
  65. }


  68. class Consumer implements Runnable
  69. {
  70.          private Resource res;
  71.          
  72.          Consumer(Resource res)
  73.          {
  74.                  this.res=res;       
  75.          }
  76.          public void run()
  77.          {
  78.                  while(true)
  79.           {
  80.                   res.out();       
  81.           }
  82.          }
  83. }
复制代码
D:\java0218\day06>java ProducerConsumerDemo
Thread-0...生产者...+商品+--1
Thread-1...消费者...+商品+--1
Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
        at java.lang.Object.notify(Native Method)
        at Resource.out(ProducerConsumerDemo.java:44)
        at Consumer.run(ProducerConsumerDemo.java:80)
        at java.lang.Thread.run(Thread.java:744)


大家好  运行的时候出现上边提示 我看不懂 哪位大神帮我分析下这个是什么意思啊  代码是和视频里边一模一样的  让我很郁闷！





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