package 多线程;import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;public class PandCnewLock {public static void main(String[] args) {
//          Producer p= new Producer2();
//          Consumer c = new Consumer2();
//          new Thread(p,"生产者").start();
//          new Thread(p,"生产者").start();
//          new Thread(c,"消费者").start();
//          new Thread(c,"消费者").start();new Thread(new Producer2(),"生产者").start();new Thread(new Consumer2(),"消费者").start();new Thread(new Producer2(),"生产者").start();new Thread(new Consumer2(),"消费者").start();}}class Producer2 implements Runnable{Resource2 r = Resource2.getRes();@Overridepublic void run() {while(true)r.produce("商品：");}}class Consumer2 implements Runnable{Resource2 r = Resource2.getRes();@Overridepublic void run() {while(true)r.consume();}}class Resource2{private int count;private boolean flag=false;static Resource2 r = new Resource2();Lock lock = new ReentrantLock();Condition cp = lock.newCondition();Condition cc = lock.newCondition();private Resource2() {}public static Resource2 getRes(){return r;}public void produce(String name){lock.lock();//上锁try {while(!flag)try {cp.await(); //与此 Condition 相关的锁以原子方式释放，并且出于线程调度的目的，将禁用当前线程，} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}name = name+count++;flag=false;System.out.println(Thread.currentThread().getName()+" .........生产商品："+count);cc.signal();//唤醒一个cc上等待线程。} finally {lock.unlock();}}public void consume(){lock.lock();try {while(flag)try {cc.await();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}flag=true;System.out.println(Thread.currentThread().getName()+" ======消费商品："+count);cp.signal();} finally {lock.unlock();}}}