黑马程序员技术交流社区

标题: 多线程同步疑问 [打印本页]

---

作者: fatesabering    时间: 2014-12-12 02:28
标题: 多线程同步疑问
毕老师视频中的一个例子，我稍微改了下，结果不太对，请各位大神帮忙看看问题出在哪

1. package java01;
   
2. import java.util.concurrent.locks.*;
   
3. 
   
4. class Resource
   
5. {
   
6.         private String name;
   
7.         private boolean flag=false;
   
8.         private int count=0;
   
9.         Lock lock = new ReentrantLock();
   
10.         Condition pro = lock.newCondition();
    
11.         Condition con = lock.newCondition();
    
12.        
    
13.         public void set(String name)
    
14.         {
    
15.                 lock.lock();
    
16.                 if(flag)
    
17.                         try{pro.await();}catch(Exception e){}
    
18.                 this.name=name+":"+count++;
    
19.                 System.out.println(Thread.currentThread().getName()+" 生产者 "+name);
    
20.                 flag=true;
    
21.                 con.signal();
    
22.                 lock.unlock();
    
23.         }
    
24.         public void out()
    
25.         {
    
26.                 lock.lock();
    
27.                 if(!flag)
    
28.                         try{con.await();}catch(Exception e){}
    
29.                 System.out.println(Thread.currentThread().getName()+" 消费者 "+name);
    
30.                 flag=false;
    
31.                 pro.signal();
    
32.                 lock.unlock();
    
33.         }
    
34. }
    
35. class Producer implements Runnable
    
36. {
    
37.         private Resource r;
    
38.         Producer(Resource r)
    
39.         {
    
40.                 this.r=r;
    
41.         }
    
42.         public void run()
    
43.         {
    
44.                 while(true)
    
45.                 {
    
46.                         r.set("真夜");
    
47.                 }
    
48.         }
    
49. }
    
50. class Consumer implements Runnable
    
51. {
    
52.         private Resource r;
    
53.         Consumer(Resource r)
    
54.         {
    
55.                 this.r=r;
    
56.         }
    
57.         public void run()
    
58.         {
    
59.                 while(true)
    
60.                 {
    
61.                         r.out();
    
62.                 }
    
63.         }
    
64. }
    
65. public class day1212 {
    
66.         public static void main(String[] args) {
    
67.                 Resource r = new Resource();
    
68.                 new Thread(new Producer(r)).start();
    
69.                 new Thread(new Producer(r)).start();
    
70.                 new Thread(new Consumer(r)).start();
    
71.                 new Thread(new Consumer(r)).start();
    
72.         }
    
73. }
    

复制代码

---

作者: fatesabering    时间: 2014-12-12 02:37
我不明白的是为什么打印结果中生产者后面没有个数，只有消费者后面有

---

作者: Quasimodo    时间: 2014-12-12 04:29
你set方法里面有一句 this.name=name+":"+count++;
    消费者里的name是这里的 this.name  所以会有count
    而生产者后面跟的name是传参进来的name  所以就没有个数
     你把打印生产者的那句的name改成this.name就有个数了

---

作者: fatesabering    时间: 2014-12-12 11:37

Quasimodo 发表于 2014-12-12 04:29
你set方法里面有一句 this.name=name+":"+count++;
    消费者里的name是这里的 this.name  所以会有count
...

原来如此，我明白了，竟然是这里出了问题。亏我想了半天，Σ( ° △ °|||)︴

---

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

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