java线程通讯——使用Lock和Condition代替synchronized 和 wait, notify notifyAll()

Lock 实现提供了比使用 synchronized 方法和语句可获得的更广泛的锁定操作。
此实现允许更灵活的结构，可以具有差别很大的属性，可以支持多个相关的 Condition 对象。

使用生产者和消费者为例！！！import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**

* 使用Lock和Condition代替
* synchronized 和 wait, notify notifyAll();

*/
class Resource2{
private String product;
private int count = 1;
private boolean flag= false;

private Lock lock = new ReentrantLock();

Condition condition_pro = lock.newCondition(); //鎖創建的生產者condition對象!!
Condition condition_con = lock.newCondition(); //鎖創建的消費者condition對象！！

public void produce(String product) throws InterruptedException{
lock.lock();
try {
while(flag){

condition_pro.await();
}

this.product = product+"----"+ count++;
System.out.println(Thread.currentThread().getName()+"————生產了————"+this.product);
flag= true;
condition_con.signal(); //喚醒消費者對象！！！
}finally{
lock.unlock();
}
}

public void consume() throws InterruptedException{

lock.lock();
try {
while(!flag){

condition_con.await();
}

System.out.println(Thread.currentThread().getName()+"————消費了————"+this.product);
flag= false;
condition_pro.signal(); //喚起生產者對象！！！
}finally{
lock.unlock();
}
}

}

class Producer2 implements Runnable{
private Resource2 res;

public Producer2(Resource2 res){
this.res= res;
}
@Override
public void run() {
while(true){
try {
res.produce("Iphone 7");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}
class Consumer2 implements Runnable{
private Resource2 res;

public Consumer2(Resource2 res){
this.res= res;
}
@Override
public void run() {
while(true){
try {
res.consume();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

public class ProducerComsumer2 {

public static void main(String[] args) {

Resource2 res = new Resource2();

Producer2 pro = new Producer2(res);
Consumer2 con = new Consumer2(res);

Thread t1 = new Thread(pro,"生產者1");
Thread t2 = new Thread(pro,"生產者2");
Thread t3 = new Thread(con,"消費者1");
Thread t4 = new Thread(con,"消費者2");

t1.start();
t2.start();
t3.start();
t4.start();
//new Thread(new Producer(res)).start();
//new Thread(new Consumer(res)).start();

}

}