照着毕老师的视频写的，API我也查了。我的包没导错啊，怎么会提示我lock包不存在呢？问题如图所示。

1. /*
   
2. 练习：线程间的通信—————生产者，消费者
   
3.         两个生产者，两个消费者
   
4. */
   
5. import java.util.concurrent.locks.*;
   
6. 
   
7. class Resource
   
8. {
   
9.         private String name;
   
10.         private int count = 0;
    
11.         private boolean flag = false;
    
12.         
    
13.         private Lock lock = new ReentrantLock();
    
14.         private Condition condition_pro = new lock.newCondition();
    
15.         private Condition condition_con = new lock.newCondition();
    
16. 
    
17.         public void set(String name) throws InterruptedException
    
18.         {
    
19.                 lock.lock();
    
20.                 try
    
21.                 {                                
    
22.                         while(flag)
    
23.                                 condition_pro.await();
    
24.                         this.name = name+"---"+count++;
    
25.                         System.out.println(Thread.currentThread().getName()+":::"+this.name);
    
26.                         flag = true;
    
27.                                 condition_con.signal();
    
28.                 }
    
29.                 finally
    
30.                 {
    
31.                         lock.unlock();
    
32.                 }               
    
33.                
    
34.         }
    
35.         public void out() throws InterruptedException
    
36.         {
    
37.                 lock.lock();
    
38.                 try
    
39.                 {
    
40.                         while(!flag)
    
41.                                 condition_con.await();
    
42.                         System.out.println(Thread.currentThread().getName()+"~~~~~~"+this.name);
    
43.                         flag = false;
    
44.                         condition_pro.signal();
    
45.                 }
    
46.                 catch (InterruptedException e)
    
47.                 {
    
48.                         lock.unlock();
    
49.                 }
    
50.                
    
51.         }
    
52. }
    
53. 
    
54. //生产者
    
55. class Produc implements Runnable
    
56. {
    
57.         Resource r;
    
58.         Produc(Resource r)
    
59.         {
    
60.                 this.r = r;
    
61.         }
    
62.         public void run()
    
63.         {
    
64.                 while(true)
    
65.                 {
    
66.                         try
    
67.                         {
    
68.                                 r.set("曲曲曲");
    
69.                         }
    
70.                         catch (InterruptedException e)
    
71.                         {
    
72.                         }
    
73.                         
    
74.                 }
    
75.         }
    
76. }
    
77. 
    
78. //消费者
    
79. class Consum implements Runnable
    
80. {
    
81.         Resource r;
    
82.         Consum(Resource r)
    
83.         {
    
84.                 this.r = r;
    
85.         }
    
86.         public void run()
    
87.         {
    
88.                 while(true)
    
89.                 {
    
90.                         try
    
91.                         {
    
92.                                 r.out();
    
93.                         }
    
94.                         catch (InterruptedException e)
    
95.                         {
    
96.                         }
    
97.                         
    
98.                 }
    
99.         }
    
100. }
     
101. class  LockDemo
     
102. {
     
103.         public static void main(String[] args)
     
104.         {
     
105.                 Resource r = new Resource();
     
106.                 Produc pr = new Produc(r);
     
107.                 Consum co = new Consum(r);
     
108. 
     
109.                 Thread t1 = new Thread(pr);
     
110.                 Thread t2 = new Thread(pr);
     
111.                 Thread t3 = new Thread(co);
     
112.                 Thread t4 = new Thread(co);
     
113. 
     
114.                 t1.start();
     
115.                 t2.start();
     
116.                 t3.start();
     
117.                 t4.start();
     
118.         }
     
119. }
     

复制代码

把这个地方的new 去掉就好了  条件是绑定在已有的lock对象上的不用new

夜半风 发表于 2014-9-8 11:20
把这个地方的new 去掉就好了  条件是绑定在已有的lock对象上的不用new

你再好好看看 毕老师的视频 应该也没有new

这是毕老师的原版代码 你看看

夜半风 发表于 2014-9-8 11:25
这是毕老师的原版代码 你看看

原来问题出在这啊。谢谢啊。
编译器说是包不存在，我就没把注意力放在new上…………

学习啦，一起努力

newCondition() 是lock的方法，不用new

估计就是习惯性的写上new了

过来学习的