毕老师的视频教程多线程中有一个经典例子，使用Lock+Condition来替代Synchronize。
其中的Condition_p 和 Condition_c 是如何跟线程绑定的？使得lock可以把当前线程分成两种情况来管理？
例子中两个生产线程t1，t2,两个消费线程t3 , t4并没有显式地与Condition_p 和 Condition_c绑定，
我们只知道Condition_p结束后会唤醒Condition_c，Condition_c结束后会唤醒Condition_p.

个人的理解是，两类线程通过程序的入口来实现的绑定，Producer的入口是set(),进去后就是Condition_p，而Consumer的入口是out(),进去后就是Condition_c，

1. <p>package com.practise;
   
2. import java.util.concurrent.locks.*;
   
3. </p><p>
   
4. public class Lock {
   
5. </p><p> /**
   
6.   * @param args
   
7.   */
   
8. public static void main(String[] args) {
   
9.   // TODO Auto-generated method stub</p><p>  Resource res=new Resource();
   
10.   Thread pro1=new Thread(new Producer(res));
    
11.   Thread pro2=new Thread(new Producer(res));
    
12.   
    
13.   Thread con1=new Thread(new Consumer(res));
    
14.   Thread con2=new Thread(new Consumer(res));
    
15.   pro1.start();
    
16.   pro2.start();
    
17.   con1.start();
    
18.   con2.start();
    
19.   }
    
20. }
    
21. </p><p>
    
22. class Resource{
    
23. private String name;
    
24. private int count=1;
    
25. private boolean flag=false;
    
26. 
    
27. private ReentrantLock lock=new ReentrantLock();
    
28. //此处为什么我写成private Lock lock=new ReentrantLock();会报错,这个向上转型有问题么？毕老师的是正常的~！难道又是版本问题？
    
29. </p><p>
    
30. private Condition condition_p=lock.newCondition();
    
31. private Condition condition_c=lock.newCondition();
    
32. 
    
33. public void set(String name)throws InterruptedException{
    
34.   lock.lock();
    
35.   try{
    
36.   while(flag)
    
37.    condition_p.await();
    
38.   this.name=name+"..."+count++;
    
39.   System.out.println(Thread.currentThread().toString()+"...producer..."+this.name);
    
40.   flag=true;
    
41.   condition_c.signal();
    
42. }
    
43.   finally{
    
44.    lock.unlock();
    
45.   }
    
46. }
    
47. public void out()throws InterruptedException{
    
48.   lock.lock();
    
49.   try{
    
50.    while(!flag)
    
51.     condition_c.await();
    
52.    System.out.println(Thread.currentThread().toString()+"......consumer......"+this.name);
    
53.    flag=false;
    
54.    condition_p.signal();
    
55.   }
    
56.   finally{
    
57.    lock.unlock();
    
58.   }
    
59. }
    
60. }</p><p>class Producer implements Runnable{
    
61. private Resource res;
    
62. Producer(Resource res)
    
63. {
    
64.   this.res=res;
    
65. }
    
66. public void run(){
    
67.   while(true)
    
68.    try {
    
69.     res.set("商品");
    
70.    } catch (InterruptedException e) {
    
71.     // TODO Auto-generated catch block
    
72.     e.printStackTrace();
    
73.    }  
    
74. }
    
75. }</p><p>class Consumer implements Runnable{
    
76. private Resource res;
    
77. Consumer(Resource res)
    
78. {
    
79.   this.res=res;
    
80. }
    
81. public void run(){
    
82.   while(true)
    
83.    try {
    
84.     res.out();
    
85.    } catch (InterruptedException e) {
    
86.     // TODO Auto-generated catch block
    
87.     e.printStackTrace();
    
88.    }  
    
89. }
    
90. }</p><p> </p>

复制代码

多谢版主鼓励，总算长分了呀~!{:soso_e109:}

我就这么写的，没问题的，  是不是你没导包？？  你看下