A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

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();
                }
        }
}

评分

参与人数 1技术分 +1 收起 理由
房宝彬 + 1

查看全部评分

8 个回复

倒序浏览
仔细在看看视频  肯定能解决问题 ,。是不是哪里漏掉了、
回复 使用道具 举报
Resource类中定义的set(),out()方法抛出了InterruptedException异常,调用他们的话需要捕捉异常。
       try{
        res.set("+商品+");
           }
      catch (InterruptedException e)
        {
                  }

评分

参与人数 1技术分 +1 收起 理由
房宝彬 + 1

查看全部评分

回复 使用道具 举报
很明显,这是产生了中断异常,如楼上只要处理一下异常就可以了。
回复 使用道具 举报
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(){}都会出问题的。
回复 使用道具 举报
哦了,谢谢大家了
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马