使用jdk1.5的多线程 lock condition 实现方式实现 生产者消费者问题

import java.util.concurrent.locks.*;
//描述产品
class Clothes
{
	//产品名称
    private String name;
	//产品价格
	private double price;
	//存放产品的容器
	private Clothes[] arr = new Clothes[100];
	//创建一把锁
	private Lock lock =new ReentrantLock();
	//创建和锁绑定的Condition对象，控制生产线程
	private Condition pro = lock.newCondition();
	//创建和锁绑定的Condition对象，控制消费线程
	private Condition con = lock.newCondition();
	//生产使用的下标
	private int propointer;
	//消费使用的下标
	private int conpointer;
	//记录产品数量
	private int count;

	public Clothes(){}
	public Clothes(String name,double price)
	{
		this.name = name;
		this.price = price;
	}
	//生产功能
	public void produce()
	{
		lock.lock();
		try
		{
			//先判断该不该生产，当容器满的时候不能生产
			while(count==arr.length)
			{
				try{pro.await();}catch(InterruptedException e){e.printStackTrace();}
			}
			arr[propointer]=new Clothes("衬衣",99.99);
            System.out.println(Thread.currentThread().getName()+"...生产了"+arr[propointer]+"..."+count);
			count++;//数量加1
			if(++propointer==arr.length)
				propointer=0;
			con.signal();
		}
		finally
		{
			lock.unlock();
		}
	}
	//消费功能
	public void consume()
	{
		lock.lock();
		try
		{
			//先判断该不该消费，当商品数量为0 的时候，不能消费
			while(count==0)
			{
				try{con.await();}catch(InterruptedException e){e.printStackTrace();}
			}
			Clothes yifu = arr[conpointer];
			System.out.println(Thread.currentThread().getName()+"...消费了"+yifu);
            count--;
            if(++conpointer==arr.length)
				conpointer=0;
            pro.signal();
		}
		finally
		{
			lock.unlock();
		}
	}

	public String toString()
	{
		return name+","+price;
	}

}
class Producer implements Runnable
{
	private Clothes clo;
	public Producer(Clothes clo)
	{
		this.clo = clo;
	}
	public void run()
	{
	    while(true)
		{
			clo.produce();
		}
	}
}
class Consumer implements Runnable
{
	private Clothes clo;
	public Consumer(Clothes clo)
	{
		this.clo = clo;
	}
	public void run()
	{
		while(true)
		{
			clo.consume();
		}
	}
}
class Demo6 
{
	public static void main(String[] args) 
	{
		Clothes clo = new Clothes();

		Producer producer = new Producer(clo);

		Consumer consumer = new Consumer(clo);

		Thread t1 = new Thread(producer);
		Thread t2 = new Thread(producer);

		Thread t3 = new Thread(consumer);
		Thread t4 = new Thread(consumer);

		t1.start();
		t2.start();
		t3.start();
		t4.start();


	}
}