多线程（一）生产者消费者问题！！！（原创）

 

package test;
/**
 * @author  E-mail:[e-mail]
 * @version 创建时间：2011-11-21 上午09:14:58
 * 类说明
 */
public class CaoYang {
	static public void main(String[] args){
		
		Loufeng loufeng=new Loufeng(3) ;
		
		new XiaoJie("嘉新",loufeng,1000).start() ;
		new XiaoJie("萝莉",loufeng,1000).start() ;
		new XiaoJie("诗情",loufeng,1000).start() ;
		new KeRen("张三",loufeng,1000).start() ;
		new KeRen("李四",loufeng,1000).start() ;
		new KeRen("王五",loufeng,1000).start() ;
		
		
		
		
	}

}

 package test;

import java.util.Random;

/**
 * @author E-mail:[e-mail]
 * @version 创建时间：2011-11-21 上午09:14:04
 * 类说明
 */
public class KeRen extends Thread{
	
	private final Random random ;
	private final Loufeng loufeng ;
	public KeRen(String name ,Loufeng loufeng,long l){
		super(name) ;
		this.loufeng=loufeng ;
		random=new Random(l) ;
	}
	
	public void run(){
		
		try{
			while(true){
				String cake=loufeng.get() ;
				System.out.println("完成交易："+cake) ;
				Thread.sleep(random.nextInt(1000)) ;
			}
		}catch(Exception e){
			e.printStackTrace() ;
		}
		
	}
	
	

}

 package test;

/**
 * @author  E-mail:[e-mail]
 * @version 创建时间：2011-11-21 上午09:14:42
 * 类说明 
 */
public class Loufeng {
	
	
	private int count ;
	private int zou  ;//当前要出台的
	private  int hui ;//当前新回来的
	private final String buffer[] ;
	public Loufeng(Integer sum){
		this.buffer=new String[3] ;
		this.count=0 ;
		this.zou=0 ;
		this.hui=0 ;
	}
	
	public synchronized void put(String xiaoj) throws InterruptedException{
		System.out.println(Thread.currentThread().getName()+xiaoj) ;
		while(count>=buffer.length){
			wait() ;
		}
		
		buffer[hui]=xiaoj ;
		hui=(hui+1)%buffer.length ;
		
		count++ ;
		System.out.println("库存量=============="+count) ;
		this.notifyAll() ;
		
	}
	public synchronized String get() throws InterruptedException{
		while(count<=0){
			wait() ;
		}
		
		String taak=buffer[zou] ;
		zou=(zou+1)%buffer.length ;
		count-- ;
		this.notifyAll() ;
		System.out.println(Thread.currentThread().getName()+"准备带走"+taak) ;
		return taak; 
		}
	

}

 package test;

import java.util.Random;

/**
 * @author  E-mail:[e-mail]
 * @version 创建时间：2011-11-21 上午09:20:59
 * 类说明
 */
public class XiaoJie extends Thread{
	private final Random random ;
	private final Loufeng  loufeng ;
	private static int i=0 ;
	public XiaoJie(String name ,Loufeng loufeng,long feed){
		super(name) ;
		this.loufeng=loufeng ;
		this.random=new Random(feed) ;
	}
	public void run(){
		
		while(true){
			try {
				Thread.sleep(random.nextInt(1000)) ;
				String cha="序号"+getid()+"===姓名："+this.getName();
				loufeng.put(cha) ;
				
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			
		}
	}
	public static final int getid(){
		return i++ ;
	}

}