import java.util.concurrent.locks.*;
class  ProduceConsumerDemo
{
        public static void main(String[] args)
        {
                Resource r=new Resource();
                Producer pro=new Producer(r);
                Consumer con=new Consumer(r);
                Thread t1=new Thread(pro);
                Thread t2=new Thread(pro);
                Thread t3=new Thread(con);
                Thread t4=new Thread(con);
                t1.start();
                t2.start();
                t3.start();
                t4.start();
        }
}
class Resource
{
        private String name;
        private int count=1;
        private boolean flag=false;
        private Lock lock=new ReentrantLock();
        private Condition condition_pro=lock.newCondition();
        private Condition condition_con=lock.newCondition();
        public void set(String name) throws InterruptedException
        {
                lock.lock();
                try
                {
                        while(flag)
                                condition_pro.await();
                        this.name=name+"--"+count++;
                        System.out.println(Thread.currentThread().getName()+"...生产者。。"+this.name);
                        flag=true;
                        condition_con.signal();
                }
                finally
                {
                        lock.unlock();
                }
        }
        public void out()throws InterruptedException
        {
                lock.lock();
                try
                {
                        while(!flag)
                                condition_con.await();
                        System.out.println(Thread.currentThread().getName()+",,,、、、、消费者、、、"+this.name);
                        flag=false;
                        condition_pro.signal();
                }
                finally
                {
                        lock.unlock();
                }
        }
}
class Producer implements Runnable
{
        private Resource res;
        Producer(Resource res)
        {
                this.res=res;       
        }
        public void run()
        {
                while(true)
                {
                        res.set("+商品+");
                }
        }
}
class Consumer implements Runnable
{
        private Resource res;
        Consumer(Resource res)
        {
                this.res=res;       
        }
        public void run()
        {
                while(true)
                {
                        res.out();
                }
        }
}

仔细在看看视频  肯定能解决问题 ，。是不是哪里漏掉了、

Resource类中定义的set(),out()方法抛出了InterruptedException异常，调用他们的话需要捕捉异常。
       try{
        res.set("+商品+");
           }
      catch (InterruptedException e)
        {
                  }

很明显，这是产生了中断异常，如楼上只要处理一下异常就可以了。

public void set(String name) throws InterruptedException这里抛出异常了，而res.set("+商品+");调用了set(); 方法，你需对res.set("+商品+");进行异常处理才可以
public void out()throws InterruptedException  和res.out();同理

张明星 发表于 2012-3-27 19:10
Resource类中定义的set(),out()方法抛出了InterruptedException异常，调用他们的话需要捕捉异常。
       t ...

那怎么out()方法没出错呢？也没捕捉啊

张小庆 发表于 2012-3-28 08:45
那怎么out()方法没出错呢？也没捕捉啊

out()方法也需要捕捉，只是虚拟机检测到set()方法抛出的异常后，就不再向下执行了，用catch捕获到set()抛出的异常后，out()方法就出错了

public void set(String name) throws InterruptedException
public void out()throws InterruptedException
set和out方法都抛出了异常，在调用的时候得进行捕捉和处理。或者可以再抛出去。
jvm进行编译时，寻找到第一个没有捕捉、处理异常的情况后就不再编译，所以后面调用out和set不进行try{}catch(){}都会出问题的。

哦了，谢谢大家了