import java.util.LinkedList;import java.util.Queue;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.ReentrantLock;//产品class Product{	 String name=null;	public Product(String name)	{		this.name=name;	}	}class  Buffer{  private Queue
     
       queue=new LinkedList
      
       ();//一个普通队列  private final int size=5;  //最大长度为，可以自己调整  public void add(Product p)//  {	  synchronized (queue) {		  while(queue.size()==size)		  {			  System.out.println(Thread.currentThread().getName()+"队列已经满了，生产者释放锁");			  try {				queue.wait();			} catch (InterruptedException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}		  }		  queue.offer(p);		 		  System.out.println(Thread.currentThread().getName()+"入队    "+queue.size());		  		  queue.notify();			}	   }    public void remove()  {	  synchronized (queue) {		  while(queue.size()<=0)		  {			  System.out.println(Thread.currentThread().getName()+"队列为空，释放锁");			  try {				queue.wait();			} catch (InterruptedException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}		  }		  queue.poll();		  System.out.println(Thread.currentThread().getName()+"出队，剩下"+queue.size());		  queue.notify();			}	    }	}class Buffer2{ private Queue
       
          queque=new LinkedList
        
         ();private int size=5;private ReentrantLock lock=new ReentrantLock(true);private Condition notFull=lock.newCondition();private Condition notEmpty=lock.newCondition();public void add(Product p){	lock.lock();	try	{	while(queque.size()==size)	{							notFull.await();	}				queque.add(p);	notEmpty.signal();	} catch (InterruptedException e) {		// TODO Auto-generated catch block		e.printStackTrace();	}finally	{		lock.unlock();	}	}public void remove() {	try {		lock.lockInterruptibly();	} catch (InterruptedException e) {		// TODO Auto-generated catch block		e.printStackTrace();	}	try	{		while(queque.size()==0) notEmpty.await();		queque.poll();		notFull.signal();			} catch (InterruptedException e) {		// TODO Auto-generated catch block		e.printStackTrace();	}finally{		lock.unlock();			}			} 	}class Producer implements Runnable{	private Buffer2 buf;		public Producer(Buffer2 buf)	{		this.buf=buf;	}	@Override	public void run() {		// TODO Auto-generated method stub		for(int i=0;i<10;i++)		{			try {				Thread.sleep(3000);  //控制生产速度			} catch (InterruptedException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}			buf.add(new Product("zhang "+i));		}					}	}class Customer implements Runnable{  private Buffer2 buf=null;  public Customer(Buffer2 buf)  {	  this.buf=buf;  }	@Override	public void run() {		for(int i=0;i<10;i++)		{			try {				Thread.sleep(1);//控制生产速度，，			} catch (InterruptedException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}//			buf.remove();		}			}	}public class 生产消费者 {	/**	 * @param args	 */	public static void main(String[] args) {		// TODO Auto-generated method stub				//学学使用线程池		Buffer2 buf=new Buffer2();		ExecutorService exe=Executors.newCachedThreadPool();		int i=0;		while(i++<2)		{			exe.submit(new Producer(buf));					}		i=0;		while(i++<2)		{			exe.submit(new Customer(buf));		}		exe.shutdown();	}}