import java.util.concurrent.locks.*;
/*多生产者,多消费者的问题jdk1.5新特性
*/
public class ProCon{
	public static void main(String[]args){
	Res r=new Res();
	Producer p=new Producer(r);
	Consumer c=new Consumer(r);
	Thread t0=new Thread(p);
	Thread t1=new Thread(p);
	Thread t2=new Thread(c);
	Thread t3=new Thread(c);
	t0.start();
	t1.start();
	t2.start();
	t3.start();
	}
}

class Res{
	private String name;
	private int count=1;
	private boolean flag=false;
	Lock lock=new ReentrantLock();//创建一个锁对象
	//Condition con=lock.newCondition();通过已有的锁获取该锁上的监视器对象
	//通过已有的锁获取两组监视器,一组监视生产者,一组监视消费者
	Condition producer_con=lock.newCondition();
	Condition consumer_con=lock.newCondition();
	public void set(String name){
		lock.lock();
		try{
			while(flag)	
			try{producer_con.await();}catch(InterruptedException e){}
			this.name=name+count;
			count++;
			System.out.println(Thread.currentThread().getName()+"..生产者.."+this.name);	
			flag=true;
			consumer_con.signal();
		}
		finally{
			lock.unlock();
			}
		
	}
	public void out(){
	lock.lock();
		try{
		while(! flag)	
			try{consumer_con.await();}catch(InterruptedException e){}
			System.out.println(Thread.currentThread().getName()+".......消费者....."+this.name);
			flag=false;
			producer_con.signal();
		}
		finally{
			lock.unlock();
			}
	}
}

class Producer implements Runnable{
	private Res r;
	Producer(Res r){
	this.r=r;
	}
	public void run(){
		while(true){
		r.set("烤鸭");
		}
	}

}

class Consumer implements Runnable{
	private Res r;
	Consumer(Res r){
	this.r=r;
	}
	public void run(){
		while(true){
		r.out();
		}
	}

}