1. import java.util.concurrent.locks.*;
   
2. 
   
3. class ProducerConsumerDemo2
   
4. {
   
5.         public static void main(String[] args)
   
6.         {
   
7.                 Resource res = new Resource();
   
8. 
   
9.                 Producer pro = new Producer(res);
   
10.                 Consumer con = new Consumer(res);
    
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.                 t1.start();
    
17.                 t2.start();
    
18.                 t3.start();
    
19.                 t4.start();
    
20.         }
    
21. }
    
22. class Resource
    
23. {
    
24.         private String name;
    
25.         private int count = 1;
    
26.         private boolean flag = false;
    
27.         //多态。创建锁。
    
28.         private Lock lock = new ReentrantLock();
    
29.         //调用lock的newCondition方法,获得condition对象。
    
30.         private Condition condition = lock.newCondition();
    
31. 
    
32.         public  void set(String name)throws InterruptedException
    
33.         {
    
34.                 lock.lock();
    
35.                 try
    
36.                 {
    
37.                         while(flag)
    
38.                                 condition.await();//等待状态。
    
39.                         this.name = name+"---"+count++;
    
40.                         System.out.println(Thread.currentThread().getName()+"---消费者---"+this.name);
    
41.                         flag = true;
    
42.                         condition.signalAll();//唤醒线程。
    
43.                 }
    
44.                 finally
    
45.                 {
    
46.                         lock.unlock();
    
47.                 }               
    
48.         }
    
49.         public  void out()throws InterruptedException
    
50.         {
    
51.                 lock.lock();
    
52.                 try
    
53.                 {                       
    
54.                         while(!flag)
    
55.                                 condition.await();
    
56.                         System.out.println(Thread.currentThread().getName()+"---生产者---"+this.name );
    
57.                         flag = false;
    
58.                         condition.signalAll();                       
    
59.                 }
    
60.                 finally
    
61.                 {
    
62.                         lock.unlock();
    
63.                 }               
    
64.         }
    
65. }
    
66. class Producer implements Runnable
    
67. {
    
68.         private Resource res;
    
69.         Producer(Resource res)
    
70.         {
    
71.                 this.res = res;
    
72.         }
    
73.         public void run()
    
74.         {
    
75.                 while(true)
    
76.                 {
    
77.                         try
    
78.                         {
    
79.                                 res.set("|商品|");
    
80.                         }
    
81.                         catch (InterruptedException e)
    
82.                         {
    
83.                         }                       
    
84.                 }
    
85.         }
    
86. }
    
87. class Consumer implements Runnable
    
88. {
    
89.         private Resource res;
    
90.         Consumer(Resource res)
    
91.         {
    
92.                 this.res = res;
    
93.         }
    
94.         public void run()
    
95.         {
    
96.                 while (true)
    
97.                 {
    
98.                         try
    
99.                         {
    
100.                                 res.out();
     
101.                         }
     
102.                         catch (InterruptedException e)
     
103.                         {
     
104.                         }                       
     
105.                 }
     
106.         }
     
107. }

复制代码

编译时产生6个问题。
-------------------------------------------------------
ProducerConsumerDemo2.java:32: 不兼容的类型
找到： java.util.concurrent.locks.ReentrantLock
需要： Lock
        private Lock lock = new ReentrantLock();
                            ^
ProducerConsumerDemo2.java:34: 找不到符号
符号： 方法 newCondition()
位置： 类 Lock
        private Condition condition = lock.newCondition();
                                          ^
ProducerConsumerDemo2.java:38: 找不到符号
符号： 方法 lock()
位置： 类 Lock
                lock.lock();
                    ^
ProducerConsumerDemo2.java:50: 找不到符号
符号： 方法 unlock()
位置： 类 Lock
                        lock.unlock();
                            ^
ProducerConsumerDemo2.java:55: 找不到符号
符号： 方法 lock()
位置： 类 Lock
                lock.lock();
                    ^
ProducerConsumerDemo2.java:66: 找不到符号
符号： 方法 unlock()
位置： 类 Lock
                        lock.unlock();
                            ^
6 错误
-------------------------------------------------
但是把import java.util.concurrent.locks.*;
换成：import java.util.concurrent.locks.Lock;
         import java.util.concurrent.locks.ReentrantLock;
         import java.util.concurrent.locks.Condition;
就没有问题。

这时什么原因呢？

两种导入包的方式没有差别呀，没出现你说的编译问题。

呆呆沙师妹 发表于 2014-4-15 09:13
两种导入包的方式没有差别呀，没出现你说的编译问题。

我用的是Editplus编译运行的