黑马程序员技术交流社区

标题: 关于多线程等待唤醒机制的运行问题 [打印本页]

---

作者: 武维京    时间: 2014-6-2 10:23
标题: 关于多线程等待唤醒机制的运行问题

1. package InputOputcom;
   
2. 
   
3. import java.util.concurrent.locks.Condition;
   
4. import java.util.concurrent.locks.Lock;
   
5. import java.util.concurrent.locks.ReentrantLock;
   
6. 
   
7. 
   
8. 
   
9. 
   
10. 
    
11. public class ProducerConsumerDemo1 {
    
12. 
    
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();
    
26. 
    
27.         }
    
28. 
    
29. }
    
30. 
    
31. 
    
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. }
    
74. 
    
75. 
    
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. }
    
93. 
    
94. 
    
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中没有运行结果。
有没有大神告知下是什么问题？

---

作者: superob123    时间: 2014-6-2 11:21
flag = false;试试把这句话改成 flag=true。还有把while(flag)里的await()和其他执行语句分开，还有变量名设合理一点，最好有需求分析和注解，看这代码看得蛋都碎了

---

作者: 万彪    时间: 2014-6-2 11:42
最好养成边写代码边注释的过程，100行的代码能看过来，等以后工作或编写时上千上万行代码没代码自己都不知道自己写了什么

---

作者: 丁绍然    时间: 2014-6-2 12:13
我用ecilpse也不输出东西。语法没问题
你直接用cmd试试

---

作者: 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;
   
4. 
   
5. 
   
6. 
   
7. 
   
8. 
   
9. public class ProducerConsumerDemo1 {
   
10. 
    
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();
    
24. 
    
25.         }
    
26. 
    
27. }
    
28. 
    
29. 
    
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. }
    
73. 
    
74. 
    
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. }
    
92. 
    
93. 
    
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

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;
   
4. 
   
5. 
   
6. 
   
7. 
   
8. 
   
9. public class ProducerConsumerDemo1 {
   
10. 
    
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();
    
24. 
    
25.         }
    
26. 
    
27. }
    
28. 
    
29. 
    
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. }
    
73. 
    
74. 
    
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. }
    
92. 
    
93. 
    
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
Resource类中的while（flag）这一句出的问题，while只是控制循环标记的判断，但是你将生产不走也和休眠代码放在了一起，已启动可不得没用反应麽！

---

作者: heima_xyu    时间: 2014-6-2 12:47
学到了，学到了

---

作者: 倪大大    时间: 2014-6-2 14:09
哥们 我只想说没有注解的代码 真心看不下去

---

作者: 武维京    时间: 2014-6-2 21:00

superob123 发表于 2014-6-2 11:21
flag = false;试试把这句话改成 flag=true。还有把while(flag)里的await()和其他执行语句分开，还有变量名 ...

呵呵   谢谢你改的代码 我知道哪错了！！！  当时着急问问题没想注释的问题！！！
下次提问  我会加注释的！！！谢谢指正！！！！

---

作者: 小周务商    时间: 2014-6-2 23:00
这代码真是长啊。。。。。。。。。。。。。。。

---

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

黑马程序员IT技术论坛 X3.2