黑马程序员技术交流社区

标题: 关于异常和线程的问题,哪位高手帮忙解决下啊。 [打印本页]

作者: 孙浩迪    时间: 2012-6-11 21:25
标题: 关于异常和线程的问题,哪位高手帮忙解决下啊。
package day1;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class LockDemo {

        public static void main(String[] args) {
               
                   Lockc  ck = new Lockc();
                   producer p = new producer (ck);
                   consumer c= new consumer(ck);
                  
                   Thread t1  = new Thread(p);
                   Thread t2 =  new Thread(p);
                   Thread t3 = new Thread(c);
                   Thread t4 = new Thread(c);
                  
                   t1.start();
                   t2.start();
                   t3.start();
                   t4.start();
        }
       
}
class Lockc{
       
        private String name;
        public int cuu=1;
        private boolean o = false;
       
        Lock  kk =  new ReentrantLock();
        Condition  ll_1 = kk.newCondition();
        Condition  ll_2 = kk.newCondition();
       
        public void set(String name) throws InterruptedException{
                   kk.lock();
                  
                       while(o)
                          
                               try {
                                     ll_1.await();     //t1  t2
                                     this.name=name+"....."+cuu++;
                                               
                                 System.out.println("生产者...................."+this.name+"..........");
                                 o=true;
                                ll_2.signal();
                        }finally{
                               
                                 kk.unlock();
                        }                  
        }
        public  void out() throws InterruptedException{
                  
                  kk.lock();
                  
                       while(!o)
                        try {   
                     
                                 ll_2.await();   //t3 t4
                                  System.out.println("消费者"+"...........");
                                 o = false;
                                 ll_1.signal();       
                        } finally{               
                                 kk.unlock();
                        }
        }
}

class producer implements Runnable{
        private Lockc lo;
        producer (Lockc lo){
                this.lo = lo;
        }

        @Override
        public void run() {
                  
                while(true){
                        // if(lo.cuu>0)
                         try {
                                lo.set("++商品++");
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                }       
        }
}
class consumer implements Runnable{
     private Lockc lo;
     consumer(Lockc lo){
              this.lo = lo;
     }
        @Override
        public void run() {
               
                while(true){
                         try {
                                lo.out();
                        } catch (InterruptedException e) {
                                e.printStackTrace();
                        }
                }
        }

}


为什么while(o)在try外面,能启动线程,而不执行代码,
当我把whiile(o)拿到try{}里面, 如: try{
   while(o)
}
就能正常的运行代码,  真分不清这两种有什么不同,希望高手来解答。


作者: 梁小波    时间: 2012-6-11 22:18
首先while(o)ll_await();就相当于while(o){ll_await();}
我觉得你是没有把这一点想清楚吧;
因为try-catch是一个语句块,就好像一个{}这样;在外面的时候,她就相当与是while(o){ll_await();   ...} 单纯放里面是只会执行ll_await();
而在里面的时候你如果加上{}我觉得效果一样;不知道你加上了没有?
作者: 孙浩迪    时间: 2012-6-13 17:34
梁小波 发表于 2012-6-11 22:18
首先while(o)ll_await();就相当于while(o){ll_await();}
我觉得你是没有把这一点想清楚吧;
因为try-catch ...

放里面为什么就不执行,while循环了,为什么只执行ll_await();  我里面明明有while()的
作者: 梁小波    时间: 2012-6-13 20:25
sunhaodi 发表于 2012-6-13 17:34
放里面为什么就不执行,while循环了,为什么只执行ll_await();  我里面明明有while()的 ...

我不知道你是否是这样写的
  1.      try { while(o)
  2.                                      ll_1.await();   
  3.                                      this.name=name+"....."+cuu++;
  4.                                                 
  5.                                  System.out.println("生产者...................."+this.name+"..........");
  6.                                  o=true;
  7.                                 ll_2.signal();
复制代码
这样的话只会执行 ll_1.await();  
你如果是不明白这儿,回复我;
如果你的问题不是这儿;
并且你也明白while(o)ll_await();就相当于while(o){ll_await();}
而不是
  1. while(o){
  2.                                ll_1.await();   
  3.                                      this.name=name+"....."+cuu++;
  4.                                                 
  5.                                  System.out.println("生产者...................."+this.name+"..........");
  6.                                  o=true;
  7.                                 ll_2.signal();}
复制代码
也同样回复我,可以加我qq我们具体讨论一下,好吗?
作者: 孙浩迪    时间: 2012-6-13 22:05
while(o){
                           try {
                                  11_1.await();
                               this.name=name+"....."+cuu++;
                                                
                                 System.out.println("生产者...................."+this.name+"..........");
                                 o=true;
                 }
                                   
                                ll_2.signal();}


我这样写的。。。。 就不执行里面的






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