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

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第36,37,38,39届Android交流区 › 正文

关于多线程等待唤醒机制的运行问题

© 武维京 高级黑马   /  2014-6-2 10:23  /  1344 人查看  /  10 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

  1. package InputOputcom;

  3. import java.util.concurrent.locks.Condition;
  4. import java.util.concurrent.locks.Lock;
  5. import java.util.concurrent.locks.ReentrantLock;





  11. public class ProducerConsumerDemo1 {

  13.         public static void main(String[] args) {
  14.                 Resource1 r = new Resource1();
  15.                  Producer1 p =new  Producer1(r);
  16.                  Consumer1 c=new Consumer1(r);
  17.                  
  18.                  Thread t1 = new Thread(p);
  19.                  Thread t2 = new Thread(p);
  20.                  Thread t3 = new Thread(c);
  21.                  Thread t4 = new Thread(c);
  22.                  t1.start();
  23.                  t2.start();
  24.                  t3.start();
  25.                  t4.start();

  27.         }

  29. }


  32. class Resource1{
  33.         private String name;
  34.         private int count=1;
  35.         private boolean flag = false;
  36.         private Lock lock = new ReentrantLock();
  37.         private Condition con_pro = lock.newCondition();
  38.         private Condition con_con = lock.newCondition();
  39.         public  void set(String name)throws InterruptedException{
  40.                 lock.lock();
  41.                 try {
  42.                 while(flag) {
  43.                        
  44.                                 con_pro.await();
  45.                        
  46.                
  47.                 this.name=name+"--"+count++;
  48.                 System.out.println(Thread.currentThread().getName()+"生产者..."+this.name);
  49.                 flag=true;
  50.                 con_con.signal();
  51.                 }
  52.                 }
  53.                 finally{
  54.                         lock.unlock();
  55.                 }
  56.                
  57.         }
  58.         public  void out() throws InterruptedException{
  59.                 lock.lock();
  60.                 try{
  61.                 while(!flag) {
  62.                        
  63.                   con_con.await();
  64.                 System.out.println(Thread.currentThread().getName()+"消费者........."+this.name);
  65.                  flag = false;
  66.                 con_pro.signal();
  67.                 }
  68.                 }
  69.                 finally{
  70.                         lock.unlock();
  71.                 }
  72.         }
  73. }


  76. class Producer1 implements Runnable{
  77.          private Resource1 res;
  78.          Producer1(Resource1 res){
  79.                  this.res=res;
  80.                  
  81.          }
  82.          public void run(){
  83.                  while(true){
  84.                          try {
  85.                                 res.set("商品");
  86.                         } catch (InterruptedException e) {
  87.                                 // TODO Auto-generated catch block
  88.                                 e.printStackTrace();
  89.                         }
  90.                  }
  91.          }
  92. }


  95. class Consumer1 implements Runnable{
  96.         private  Resource1 res;
  97.         Consumer1(Resource1 res){
  98.                 this.res=res;
  99.         }
  100.         public void run(){
  101.                 while(true){
  102.                         try {
  103.                                 res.out();
  104.                         } catch (InterruptedException e) {
  105.                                 // TODO Auto-generated catch block
  106.                                 e.printStackTrace();
  107.                         }
  108.                 }
  109.         }
  110. }
复制代码

我在Eclipse中没有运行结果。
有没有大神告知下是什么问题？

评分

参与人数 1技术分 +1 收起 理由
轻语。 + 1

查看全部评分

10 个回复

倒序浏览
superob123 中级黑马 2014-6-2 11:21:26
| 只看该作者
沙发
flag = false;试试把这句话改成 flag=true。还有把while(flag)里的await()和其他执行语句分开，还有变量名设合理一点，最好有需求分析和注解，看这代码看得蛋都碎了

评分

参与人数 1技术分 +1 收起 理由
轻语。 + 1 很给力!

查看全部评分

回复 使用道具 举报
万彪 中级黑马 2014-6-2 11:42:25
| 只看该作者
藤椅
最好养成边写代码边注释的过程，100行的代码能看过来，等以后工作或编写时上千上万行代码没代码自己都不知道自己写了什么
回复 使用道具 举报
丁绍然 中级黑马 2014-6-2 12:13:20
| 只看该作者
板凳
我用ecilpse也不输出东西。语法没问题
你直接用cmd试试
回复 使用道具 举报
superob123 中级黑马 2014-6-2 12:23:17
| 只看该作者
报纸
哎，为了分，给你回个详细的修改代码，就是按我上个回复改就行了
  1. import java.util.concurrent.locks.Condition;
  2. import java.util.concurrent.locks.Lock;
  3. import java.util.concurrent.locks.ReentrantLock;





  9. public class ProducerConsumerDemo1 {

  11.         public static void main(String[] args) {
  12.                 Resource1 r = new Resource1();
  13.                  Producer1 p =new  Producer1(r);
  14.                  Consumer1 c=new Consumer1(r);
  15.                  
  16.                  Thread t1 = new Thread(p);
  17.                  Thread t2 = new Thread(p);
  18.                  Thread t3 = new Thread(c);
  19.                  Thread t4 = new Thread(c);
  20.                  t1.start();
  21.                  t2.start();
  22.                  t3.start();
  23.                  t4.start();

  25.         }

  27. }


  30. class Resource1{
  31.         private String name;
  32.         private int count=1;
  33.         private boolean flag = false;
  34.         private Lock lock = new ReentrantLock();
  35.         private Condition con_pro = lock.newCondition();
  36.         private Condition con_con = lock.newCondition();
  37.         public  void set(String name)throws InterruptedException{
  38.                 lock.lock();
  39.                 try {
  40.                 while(flag) {
  41.                         
  42.                                 con_pro.await();
  43.                         
  44.                 }
  45.                 this.name=name+"--"+count++;
  46.                 System.out.println(Thread.currentThread().getName()+"生产者..."+this.name);
  47.                 flag=true;
  48.                 con_con.signal();
  49.                 }
  50.                
  51.                 finally{
  52.                         lock.unlock();
  53.                 }
  54.                
  55.         }
  56.         public  void out() throws InterruptedException{
  57.                 lock.lock();
  58.                 try{
  59.                 while(!flag) {
  60.                         
  61.                   con_con.await();
  62.                 }
  63.                 System.out.println(Thread.currentThread().getName()+"消费者........."+this.name);
  64.                  flag = true;
  65.                 con_pro.signal();
  66.                 }
  67.                
  68.                 finally{
  69.                         lock.unlock();
  70.                 }
  71.         }
  72. }


  75. class Producer1 implements Runnable{
  76.          private Resource1 res;
  77.          Producer1(Resource1 res){
  78.                  this.res=res;
  79.                  
  80.          }
  81.          public void run(){
  82.                  while(true){
  83.                          try {
  84.                                 res.set("商品");
  85.                         } catch (InterruptedException e) {
  86.                                 // TODO Auto-generated catch block
  87.                                 e.printStackTrace();
  88.                         }
  89.                  }
  90.          }
  91. }


  94. class Consumer1 implements Runnable{
  95.         private  Resource1 res;
  96.         Consumer1(Resource1 res){
  97.                 this.res=res;
  98.         }
  99.         public void run(){
  100.                 while(true){
  101.                         try {
  102.                                 res.out();
  103.                         } catch (InterruptedException e) {
  104.                                 // TODO Auto-generated catch block
  105.                                 e.printStackTrace();
  106.                         }
  107.                 }
  108.         }
  109. }
复制代码
回复 使用道具 举报
superob123 中级黑马 2014-6-2 12:32:10
| 只看该作者
地板
superob123 发表于 2014-6-2 12:23
哎，为了分，给你回个详细的修改代码，就是按我上个回复改就行了

晕上面的是没改成的，这才是改了的


  1. import java.util.concurrent.locks.Condition;
  2. import java.util.concurrent.locks.Lock;
  3. import java.util.concurrent.locks.ReentrantLock;





  9. public class ProducerConsumerDemo1 {

  11.         public static void main(String[] args) {
  12.                 Resource1 r = new Resource1();
  13.                  Producer1 p =new  Producer1(r);
  14.                  Consumer1 c=new Consumer1(r);
  15.                  
  16.                  Thread t1 = new Thread(p);
  17.                  Thread t2 = new Thread(p);
  18.                  Thread t3 = new Thread(c);
  19.                  Thread t4 = new Thread(c);
  20.                  t1.start();
  21.                  t2.start();
  22.                  t3.start();
  23.                  t4.start();

  25.         }

  27. }


  30. class Resource1{
  31.         private String name;
  32.         private int count=1;
  33.         private boolean flag = false;
  34.         private Lock lock = new ReentrantLock();
  35.         private Condition con_pro = lock.newCondition();
  36.         private Condition con_con = lock.newCondition();
  37.         public  void set(String name)throws InterruptedException{
  38.                 lock.lock();
  39.                 try {
  40.                 while(flag) {
  41.                         
  42.                                 con_pro.await();
  43.                         
  44.                 }
  45.                 this.name=name+"--"+count++;
  46.                 System.out.println(Thread.currentThread().getName()+"生产者..."+this.name);
  47.                 flag=true;
  48.                 con_con.signal();
  49.                 }
  50.                
  51.                 finally{
  52.                         lock.unlock();
  53.                 }
  54.                
  55.         }
  56.         public  void out() throws InterruptedException{
  57.                 lock.lock();
  58.                 try{
  59.                 while(!flag) {
  60.                         
  61.                   con_con.await();
  62.                 }
  63.                 System.out.println(Thread.currentThread().getName()+"消费者........."+this.name);
  64.                  flag =false;
  65.                 con_pro.signal();
  66.                 }
  67.                
  68.                 finally{
  69.                         lock.unlock();
  70.                 }
  71.         }
  72. }


  75. class Producer1 implements Runnable{
  76.          private Resource1 res;
  77.          Producer1(Resource1 res){
  78.                  this.res=res;
  79.                  
  80.          }
  81.          public void run(){
  82.                  while(true){
  83.                          try {
  84.                                 res.set("商品");
  85.                         } catch (InterruptedException e) {
  86.                                 // TODO Auto-generated catch block
  87.                                 e.printStackTrace();
  88.                         }
  89.                  }
  90.          }
  91. }


  94. class Consumer1 implements Runnable{
  95.         private  Resource1 res;
  96.         Consumer1(Resource1 res){
  97.                 this.res=res;
  98.         }
  99.         public void run(){
  100.                 while(true){
  101.                         try {
  102.                                 res.out();
  103.                         } catch (InterruptedException e) {
  104.                                 // TODO Auto-generated catch block
  105.                                 e.printStackTrace();
  106.                         }
  107.                 }
  108.         }
  109. }
复制代码
回复 使用道具 举报
yinxjfly 高级黑马 2014-6-2 12:35:23
| 只看该作者
7#
Resource类中的while（flag）这一句出的问题，while只是控制循环标记的判断，但是你将生产不走也和休眠代码放在了一起，已启动可不得没用反应麽！
回复 使用道具 举报
heima_xyu 中级黑马 2014-6-2 12:47:59
| 只看该作者
8#
学到了，学到了
回复 使用道具 举报
倪大大 中级黑马 2014-6-2 14:09:17
| 只看该作者
9#
哥们 我只想说没有注解的代码 真心看不下去
回复 使用道具 举报
武维京 高级黑马 2014-6-2 21:00:41
| 只看该作者
10#
superob123 发表于 2014-6-2 11:21
flag = false;试试把这句话改成 flag=true。还有把while(flag)里的await()和其他执行语句分开，还有变量名 ...

呵呵   谢谢你改的代码 我知道哪错了！！！  当时着急问问题没想注释的问题！！！
下次提问  我会加注释的！！！谢谢指正！！！！
回复 使用道具 举报
小周务商 金牌黑马 2014-6-2 23:00:35
| 只看该作者
11#
这代码真是长啊。。。。。。。。。。。。。。。
回复 使用道具 举报
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马