就是毕老师多线程中的说5.0中的Lock例子

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

复制代码

执行后报错。。


ProducerConsumerDemo2.java:48: 错误: 不兼容的类型
        private Lock lock = new ReentrantLock();
                            ^
  需要: Lock
  找到:    ReentrantLock
ProducerConsumerDemo2.java:50: 错误: 找不到符号
        private Condition condition_pro = lock.newCondition();
                                              ^
  符号:   方法 newCondition()
  位置: 类型为Lock的变量 lock
ProducerConsumerDemo2.java:51: 错误: 找不到符号
        private Condition condition_con = lock.newCondition();
                                              ^
  符号:   方法 newCondition()
  位置: 类型为Lock的变量 lock
ProducerConsumerDemo2.java:57: 错误: 找不到符号
                lock.lock();
                    ^
  符号:   方法 lock()
  位置: 类型为Lock的变量 lock
ProducerConsumerDemo2.java:70: 错误: 找不到符号
                        lock.unlock();//释放锁的动作一定要执行。
                            ^
  符号:   方法 unlock()
  位置: 类型为Lock的变量 lock
ProducerConsumerDemo2.java:78: 错误: 找不到符号
                lock.lock();
                    ^
  符号:   方法 lock()
  位置: 类型为Lock的变量 lock
ProducerConsumerDemo2.java:89: 错误: 找不到符号
                        lock.unlock();
                            ^
  符号:   方法 unlock()
  位置: 类型为Lock的变量 lock
7 个错误




看着架势，似乎是没导入包的问题？可是我明明在第一句import了啊。。。头疼

求解啊。。。。。。难道我这系统出错了吗

你在试试   代码没有错误  我试了   可能是其他地方出错了

重装了一次jdk，重新配置过，都没用哇。

我复制了你的代码在我的电脑中试了是可以运行的  
所以这应该是你JDK的版本的问题  可能是你ＪＤＫ版本太低
ＬＯＣＫ是１．５出现的

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

你用这两句试试

代码可以正常运行（jdk1.6），和系统应该没什么关系
使用的Eclipse吗？换成jdk1.6看看

我把需要导入的类挑出来，它却能用了{:soso__9253207014726057418_1:}
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.Condition;
但是还是没有解决问题，import java.util.concurrent.locks.*;为什么不管用了呢？？？？？

曾浩 发表于 2012-10-31 21:17
我复制了你的代码在我的电脑中试了是可以运行的  
所以这应该是你JDK的版本的问题  可能是你ＪＤＫ版本太低 ...

是官网下的最新的 1.7

吴硕 发表于 2012-10-31 21:24
代码可以正常运行（jdk1.6），和系统应该没什么关系
使用的Eclipse吗？换成jdk1.6看看 ...

用的notepad++....jdk是官网下的最新的

王永荣 发表于 2012-10-31 21:28
用的notepad++....jdk是官网下的最新的

我试了下jdk1.7运行代码，也没有任何问题

吴硕 发表于 2012-10-31 21:32
我试了下jdk1.7运行代码，也没有任何问题

哎 不管了。。我用Eclipse也能正常运行。