生产者--消费者模型（同步方式）

你的名字 2022-08-25 15:46 204阅读 0赞

package com.th2;
    
    import java.util.Hashtable;
    
    /**
     * 线程池控制类，或者说公共资源调度控制
     * 
     * @author lushuaiyin
     *
     */
    public class TControl {
    	
    	private int poolSize=20;//资源池大小
    	private int numberNow=0;//当前线程数
    	private int sleepTime=500;//线程在排队时刷新时间
    	
    	//线程的容器或者说是队列，线程池（和资源池不是一个概念），键值是线程的id
    	private Hashtable<Long, Thread> pool_product=new Hashtable<Long, Thread>();//生产队列
    	private Hashtable<Long, Thread> pool_customize=new Hashtable<Long, Thread>();//消费队列
    	//这里的队列不是真正意义上的队列，只是为了可以在这个类中能控制线程而设置的一个容器罢了，便于集中控制和监控
    	
    	private boolean montorPrint=false;//线程监视器是否打印
    	private int montorTime=500;//线程监视器打印频率
    	private MonitorThread monitor0=null;
    	
    	
    	/**
    	 * 生产
    	 */
    	public void produce(Thread th,int type){
    		if(type==1){//(排队竞争)
    			produce1(th);
    		}else if(type==2){//(优化竞争)
    			produce2(th);
    		}else{
    			
    		}
    	}
    	/**
    	 * 消费
    	 */
    	public void customize(Thread th,int type){
    		if(type==1){//(排队竞争)
    			customize1(th);
    		}else if(type==2){//(优化竞争)
    			customize2(th);
    		}else{
    			
    		}
    	}
    	
    	
    	/**
    	 * 生产(排队竞争)
    	 */
    	public synchronized void produce1(Thread th){
    		while(this.numberNow>=this.poolSize){
    			try{
    				wait();
    				Thread.sleep(sleepTime);
    			}catch(Exception e){
    				e.printStackTrace();
    			}
    		}// end while
    		
    		this.numberNow++;
    		System.out.println("$$线程"+th.getName()+" has produced new one.Now number is "+numberNow+"--$$");
    		notify();
    		
    		this.removeThread(th,1);//从生产队列中删除该线程
    	}
    	
    	/**
    	 * 消费(排队竞争)
    	 */
    	public synchronized void customize1(Thread th){
    		while(this.numberNow<=0){
    			try{
    				wait();
    				Thread.sleep(sleepTime);
    			}catch(Exception e){
    				e.printStackTrace();
    			}
    		}// end while
    		
    		this.numberNow--;
    		System.out.println("##线程"+th.getName()+" has customized one.Now number is "+numberNow+"--##");
    		notify();
    		
    		this.removeThread(th,2);//从消费队列中删除该线程
    	}
    	
    	//
    	public synchronized void changeNumberNow(int i,Thread th,int type){
    		this.numberNow=this.numberNow+i;
    		if(type==1){
    			System.out.println("$$线程"+th.getName()+" has produced new one.Now number is "+this.numberNow+"--$$");
    			this.removeThread(th,1);//从生产队列中删除该线程
    		}else if(type==2){
    			System.out.println("##线程"+th.getName()+" has customized one.Now number is "+this.numberNow+"--##");
    			this.removeThread(th,2);//从消费队列中删除该线程
    		}else{
    			
    		}
    	}
    	
    	/**
    	 * 生产(优化竞争)
    	 */
    	public void produce2(Thread th){
    		if(this.numberNow<this.poolSize){
    			changeNumberNow(1,th,1);
    		}else{
    			while(this.numberNow>=this.poolSize){
    				try{
    					th.yield();//让步，让其他线程抢占
    					System.out.println("$$线程"+th.getName()+" yield ");
    					Thread.sleep(sleepTime);
    				}catch(Exception e){
    					e.printStackTrace();
    				}
    			}// end while
    			
    			changeNumberNow(1,th,1);
    		}
    		
    	}
    	
    	
    	/**
    	 * 消费(优化竞争)
    	 */
    	public void customize2(Thread th){
    		if(this.numberNow>0){
    			changeNumberNow(-1,th,2);
    		}else{
    			while(this.numberNow<=0){
    				try{
    					th.yield();//让步，让其他线程抢占
    					Thread.sleep(sleepTime);
    				}catch(Exception e){
    					e.printStackTrace();
    				}
    			}// end while
    			
    			changeNumberNow(-1,th,2);
    		}
    		
    	}
    	
    	
    	//加入队列
    	@SuppressWarnings("unused")
    	public void addThread(Thread th,int type){
    		if(type==1){//生产
    			this.getPool_product().put(th.getId(), th);
    		}else if(type==2){//消费
    			this.getPool_customize().put(th.getId(), th);
    		}else{//其他
    			
    		}
    		
    	}
    	
    	
    	//退出队列
    	@SuppressWarnings("unused")
    	public void removeThread(Thread th,int type){
    		if(type==1){//生产
    			if(this.getPool_product().containsKey(th.getId())){
    				this.getPool_product().remove(th.getId());
    			}
    		}else if(type==2){//消费
    			if(this.getPool_customize().containsKey(th.getId())){
    				this.getPool_customize().remove(th.getId());
    			}
    		}else{//其他
    			
    		}
    		
    	}
    	
    	//启动监视器
    	public void monitor(){
    		this.monitor0=new MonitorThread(this);
    		monitor0.start();
    	}
    	
    	//停止
    	public void stopMonitor(){
    		this.setMontorPrint(false);
    	}
    	
    	//强行停止
    	public void stopMonitorStrong(){
    		if(monitor0!=null&&monitor0.isAlive()){
    			monitor0.stop();
    		}
    	}
    	
    	
    	public int getPoolSize() {
    		return poolSize;
    	}
    
    	public void setPoolSize(int poolSize) {
    		this.poolSize = poolSize;
    	}
    
    	public int getSleepTime() {
    		return sleepTime;
    	}
    
    	public void setSleepTime(int sleepTime) {
    		this.sleepTime = sleepTime;
    	}
    
    	public Hashtable<Long, Thread> getPool_product() {
    		return pool_product;
    	}
    
    	public Hashtable<Long, Thread> getPool_customize() {
    		return pool_customize;
    	}
    
    	public boolean isMontorPrint() {
    		return montorPrint;
    	}
    
    	public void setMontorPrint(boolean montorPrint) {
    		this.montorPrint = montorPrint;
    	}
    
    	public int getMontorTime() {
    		return montorTime;
    	}
    
    	public void setMontorTime(int montorTime) {
    		this.montorTime = montorTime;
    	}
    
    	public MonitorThread getMonitor0() {
    		return monitor0;
    	}
    
    
    	
    
    }

package com.th2;
    
    /**
     * 生产者线程
     * 
     * @author lushuaiyin
     *
     */
    public class PThread extends Thread{
    	
    	private TControl control;//线程池资源控制
    	public PThread(TControl control){
    		this.control=control;
    		this.getControl().addThread(this,1);//加入队列
    	}
    	
    	@Override
    	public void run() {
    		System.out.println("$"+this.getName()+"准备生产一个产品......");
    		this.getControl().produce(this,1);//第二个参数：//(1：排队竞争)(2：优化竞争)
    		//这个参数就不从外传入了，防止线程策略不同造成混乱
    	}
    	
    	public TControl getControl() {
    		return control;
    	}
    }

package com.th2;
    
    /**
     * 消费者线程
     * 
     * @author lushuaiyin
     *
     */
    public class CThread extends Thread{
    	
    	private TControl control;//线程池资源控制
    	public CThread(TControl control){
    		this.control=control;
    		this.getControl().addThread(this,2);//加入队列
    	}
    	
    	@Override
    	public void run() {
    		System.out.println("#"+this.getName()+"准备消费一个产品~~~~~~");
    		this.getControl().customize(this,1);//第二个参数：//(1：排队竞争)(2：优化竞争)
    		//这个参数就不从外传入了，防止线程策略不同造成混乱
    	}
    	
    	public TControl getControl() {
    		return control;
    	}
    }

package com.th2;
    
    /**
     * 监控线程
     * 主要是打印线程池中线程的状态和数量
     * 
     * @author lushuaiyin
     *
     */
    public class MonitorThread extends Thread{
    	
    	
    	private TControl control;//线程池资源控制
    	public MonitorThread(TControl control){
    		this.control=control;
    	}
    	
    	@Override
    	public void run() {
    		monitor(0);
    	
    	}
    	
    	public void monitor(int type){
    		while(this.getControl().isMontorPrint()){
    			String info="";
    			if(type==1){//生产
    				info="//*******************start********************//\r\n";
    				info+="生产队列目前等待线程数："+this.getControl().getPool_product().size()+"\r\n";
    				info+="//*******************end**********************//\r\n";
    				System.err.println(info);
    				try {
    					Thread.sleep(this.getControl().getMontorTime());
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    				
    			}else if(type==2){//消费
    				info="//*******************start********************//\r\n";
    				info+="消费队列目前等待线程数："+this.getControl().getPool_customize().size()+"\r\n";
    				info+="//*******************end**********************//";
    				System.err.println(info);
    				try {
    					Thread.sleep(this.getControl().getMontorTime());
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    			}else{//全部
    				info="//*******************start********************//\r\n";
    				info+="生产队列目前等待线程数："+this.getControl().getPool_product().size()+"\r\n";
    				info+="消费队列目前等待线程数："+this.getControl().getPool_customize().size()+"\r\n";
    				info+="//*******************end**********************//";
    				System.err.println(info);
    				try {
    					Thread.sleep(this.getControl().getMontorTime());
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    			}
    			this.yield();
    			
    		}//end while
    	}
    
    	public TControl getControl() {
    		return control;
    	}
    
    	
    }

package com.th2;
    
    
    public class TestMain {
    
    	public static void main(String[] args) {
    		TControl control=new TControl();
    		control.setSleepTime(1000);
    //		control.setMontorPrint(true);
    //		control.setMontorTime(100);
    //		
    //		control.monitor();//这里是监控的打印，因为都在控制台打印，所以很乱，注释掉
    		
    		for(int i=0;i<30;i++){
    			PThread productor=new PThread(control);
    			CThread customer=new CThread(control);
    			
    			customer.start();
    			productor.start();
    			
    		}
    		
    	}
    }

打印：

package com.th2;
    
    
    public class TestMain {
    
    	public static void main(String[] args) {
    		TControl control=new TControl();
    //		control.setSleepTime(500);
    //		control.setMontorPrint(true);
    //		control.setMontorTime(100);
    //		
    //		control.monitor();//这里是监控的打印，因为都在控制台打印，所以很乱，注释掉
    		
    		for(int i=0;i<30;i++){
    			PThread productor=new PThread(control);
    			CThread customer=new CThread(control);
    			
    			customer.start();
    			productor.start();
    			
    		}
    		
    	}
    }
    
    
    优化竞争
    
    打印：
    
    #Thread-1准备消费一个产品~~~~~~
    $Thread-0准备生产一个产品......
    $$线程Thread-0 has produced new one.Now number is 1--$$
    #Thread-3准备消费一个产品~~~~~~
    ##线程Thread-3 has customized one.Now number is 0--##
    #Thread-5准备消费一个产品~~~~~~
    #Thread-7准备消费一个产品~~~~~~
    #Thread-9准备消费一个产品~~~~~~
    #Thread-11准备消费一个产品~~~~~~
    #Thread-13准备消费一个产品~~~~~~
    #Thread-15准备消费一个产品~~~~~~
    #Thread-17准备消费一个产品~~~~~~
    #Thread-19准备消费一个产品~~~~~~
    #Thread-21准备消费一个产品~~~~~~
    #Thread-23准备消费一个产品~~~~~~
    #Thread-25准备消费一个产品~~~~~~
    $Thread-2准备生产一个产品......
    $$线程Thread-2 has produced new one.Now number is 1--$$
    #Thread-27准备消费一个产品~~~~~~
    ##线程Thread-27 has customized one.Now number is 0--##
    #Thread-29准备消费一个产品~~~~~~
    #Thread-31准备消费一个产品~~~~~~
    #Thread-33准备消费一个产品~~~~~~
    #Thread-35准备消费一个产品~~~~~~
    #Thread-37准备消费一个产品~~~~~~
    #Thread-39准备消费一个产品~~~~~~
    #Thread-41准备消费一个产品~~~~~~
    #Thread-43准备消费一个产品~~~~~~
    #Thread-45准备消费一个产品~~~~~~
    #Thread-47准备消费一个产品~~~~~~
    #Thread-49准备消费一个产品~~~~~~
    #Thread-51准备消费一个产品~~~~~~
    #Thread-53准备消费一个产品~~~~~~
    #Thread-55准备消费一个产品~~~~~~
    $Thread-4准备生产一个产品......
    #Thread-59准备消费一个产品~~~~~~
    #Thread-57准备消费一个产品~~~~~~
    $$线程Thread-4 has produced new one.Now number is 1--$$
    $Thread-6准备生产一个产品......
    $$线程Thread-6 has produced new one.Now number is 2--$$
    $Thread-8准备生产一个产品......
    $$线程Thread-8 has produced new one.Now number is 3--$$
    $Thread-10准备生产一个产品......
    $$线程Thread-10 has produced new one.Now number is 4--$$
    $Thread-12准备生产一个产品......
    $$线程Thread-12 has produced new one.Now number is 5--$$
    $Thread-14准备生产一个产品......
    $$线程Thread-14 has produced new one.Now number is 6--$$
    $Thread-16准备生产一个产品......
    $$线程Thread-16 has produced new one.Now number is 7--$$
    $Thread-18准备生产一个产品......
    $$线程Thread-18 has produced new one.Now number is 8--$$
    $Thread-20准备生产一个产品......
    $$线程Thread-20 has produced new one.Now number is 9--$$
    $Thread-22准备生产一个产品......
    $$线程Thread-22 has produced new one.Now number is 10--$$
    $Thread-24准备生产一个产品......
    $$线程Thread-24 has produced new one.Now number is 11--$$
    $Thread-26准备生产一个产品......
    $$线程Thread-26 has produced new one.Now number is 12--$$
    $Thread-28准备生产一个产品......
    $$线程Thread-28 has produced new one.Now number is 13--$$
    $Thread-30准备生产一个产品......
    $$线程Thread-30 has produced new one.Now number is 14--$$
    $Thread-32准备生产一个产品......
    $$线程Thread-32 has produced new one.Now number is 15--$$
    $Thread-58准备生产一个产品......
    $$线程Thread-58 has produced new one.Now number is 16--$$
    $Thread-56准备生产一个产品......
    $$线程Thread-56 has produced new one.Now number is 17--$$
    $Thread-54准备生产一个产品......
    $Thread-50准备生产一个产品......
    $Thread-48准备生产一个产品......
    $Thread-52准备生产一个产品......
    $Thread-46准备生产一个产品......
    $$线程Thread-54 has produced new one.Now number is 18--$$
    $Thread-34准备生产一个产品......
    $$线程Thread-46 has produced new one.Now number is 19--$$
    $Thread-36准备生产一个产品......
    $$线程Thread-36 yield 
    $Thread-38准备生产一个产品......
    $$线程Thread-38 yield 
    $Thread-40准备生产一个产品......
    $$线程Thread-40 yield 
    $Thread-42准备生产一个产品......
    $$线程Thread-42 yield 
    $Thread-44准备生产一个产品......
    $$线程Thread-44 yield 
    $$线程Thread-48 has produced new one.Now number is 20--$$
    $$线程Thread-52 has produced new one.Now number is 21--$$
    $$线程Thread-50 has produced new one.Now number is 22--$$
    $$线程Thread-34 has produced new one.Now number is 23--$$
    ##线程Thread-1 has customized one.Now number is 22--##
    ##线程Thread-29 has customized one.Now number is 21--##
    ##线程Thread-25 has customized one.Now number is 20--##
    ##线程Thread-23 has customized one.Now number is 19--##
    ##线程Thread-21 has customized one.Now number is 18--##
    ##线程Thread-19 has customized one.Now number is 17--##
    ##线程Thread-17 has customized one.Now number is 16--##
    ##线程Thread-15 has customized one.Now number is 15--##
    ##线程Thread-13 has customized one.Now number is 14--##
    ##线程Thread-11 has customized one.Now number is 13--##
    ##线程Thread-9 has customized one.Now number is 12--##
    ##线程Thread-7 has customized one.Now number is 11--##
    ##线程Thread-5 has customized one.Now number is 10--##
    ##线程Thread-43 has customized one.Now number is 9--##
    ##线程Thread-45 has customized one.Now number is 8--##
    $$线程Thread-44 has produced new one.Now number is 9--$$
    ##线程Thread-57 has customized one.Now number is 8--##
    ##线程Thread-31 has customized one.Now number is 7--##
    ##线程Thread-33 has customized one.Now number is 6--##
    ##线程Thread-35 has customized one.Now number is 5--##
    ##线程Thread-37 has customized one.Now number is 4--##
    ##线程Thread-39 has customized one.Now number is 3--##
    ##线程Thread-41 has customized one.Now number is 2--##
    $$线程Thread-42 has produced new one.Now number is 3--$$
    $$线程Thread-40 has produced new one.Now number is 4--$$
    $$线程Thread-38 has produced new one.Now number is 5--$$
    $$线程Thread-36 has produced new one.Now number is 6--$$
    ##线程Thread-59 has customized one.Now number is 5--##
    ##线程Thread-55 has customized one.Now number is 4--##
    ##线程Thread-53 has customized one.Now number is 3--##
    ##线程Thread-51 has customized one.Now number is 2--##
    ##线程Thread-49 has customized one.Now number is 1--##
    ##线程Thread-47 has customized one.Now number is 0--##
    
    
    第二次运行打印：
    
    #Thread-1准备消费一个产品~~~~~~
    $Thread-0准备生产一个产品......
    #Thread-3准备消费一个产品~~~~~~
    $$线程Thread-0 has produced new one.Now number is 1--$$
    ##线程Thread-3 has customized one.Now number is 0--##
    #Thread-5准备消费一个产品~~~~~~
    $Thread-2准备生产一个产品......
    $$线程Thread-2 has produced new one.Now number is 1--$$
    #Thread-7准备消费一个产品~~~~~~
    ##线程Thread-7 has customized one.Now number is 0--##
    $Thread-4准备生产一个产品......
    #Thread-23准备消费一个产品~~~~~~
    #Thread-21准备消费一个产品~~~~~~
    #Thread-19准备消费一个产品~~~~~~
    #Thread-17准备消费一个产品~~~~~~
    #Thread-15准备消费一个产品~~~~~~
    #Thread-13准备消费一个产品~~~~~~
    #Thread-11准备消费一个产品~~~~~~
    #Thread-9准备消费一个产品~~~~~~
    #Thread-25准备消费一个产品~~~~~~
    $$线程Thread-4 has produced new one.Now number is 1--$$
    $Thread-6准备生产一个产品......
    $$线程Thread-6 has produced new one.Now number is 2--$$
    #Thread-27准备消费一个产品~~~~~~
    ##线程Thread-27 has customized one.Now number is 1--##
    #Thread-29准备消费一个产品~~~~~~
    ##线程Thread-29 has customized one.Now number is 0--##
    $Thread-8准备生产一个产品......
    $$线程Thread-8 has produced new one.Now number is 1--$$
    #Thread-31准备消费一个产品~~~~~~
    ##线程Thread-31 has customized one.Now number is 0--##
    $Thread-10准备生产一个产品......
    $$线程Thread-10 has produced new one.Now number is 1--$$
    #Thread-33准备消费一个产品~~~~~~
    ##线程Thread-33 has customized one.Now number is 0--##
    #Thread-35准备消费一个产品~~~~~~
    #Thread-37准备消费一个产品~~~~~~
    $Thread-12准备生产一个产品......
    $$线程Thread-12 has produced new one.Now number is 1--$$
    #Thread-39准备消费一个产品~~~~~~
    ##线程Thread-39 has customized one.Now number is 0--##
    #Thread-41准备消费一个产品~~~~~~
    $Thread-14准备生产一个产品......
    $$线程Thread-14 has produced new one.Now number is 1--$$
    #Thread-43准备消费一个产品~~~~~~
    ##线程Thread-43 has customized one.Now number is 0--##
    #Thread-45准备消费一个产品~~~~~~
    #Thread-47准备消费一个产品~~~~~~
    $Thread-16准备生产一个产品......
    $$线程Thread-16 has produced new one.Now number is 1--$$
    #Thread-49准备消费一个产品~~~~~~
    ##线程Thread-49 has customized one.Now number is 0--##
    #Thread-51准备消费一个产品~~~~~~
    #Thread-53准备消费一个产品~~~~~~
    #Thread-55准备消费一个产品~~~~~~
    #Thread-57准备消费一个产品~~~~~~
    #Thread-59准备消费一个产品~~~~~~
    $Thread-18准备生产一个产品......
    $$线程Thread-18 has produced new one.Now number is 1--$$
    $Thread-20准备生产一个产品......
    $$线程Thread-20 has produced new one.Now number is 2--$$
    $Thread-22准备生产一个产品......
    $$线程Thread-22 has produced new one.Now number is 3--$$
    $Thread-24准备生产一个产品......
    $$线程Thread-24 has produced new one.Now number is 4--$$
    $Thread-26准备生产一个产品......
    $$线程Thread-26 has produced new one.Now number is 5--$$
    $Thread-28准备生产一个产品......
    $$线程Thread-28 has produced new one.Now number is 6--$$
    $Thread-30准备生产一个产品......
    $$线程Thread-30 has produced new one.Now number is 7--$$
    $Thread-58准备生产一个产品......
    $$线程Thread-58 has produced new one.Now number is 8--$$
    $Thread-54准备生产一个产品......
    $$线程Thread-54 has produced new one.Now number is 9--$$
    $Thread-32准备生产一个产品......
    $$线程Thread-32 has produced new one.Now number is 10--$$
    $Thread-46准备生产一个产品......
    $$线程Thread-46 has produced new one.Now number is 11--$$
    $Thread-42准备生产一个产品......
    $$线程Thread-42 has produced new one.Now number is 12--$$
    $Thread-48准备生产一个产品......
    $$线程Thread-48 has produced new one.Now number is 13--$$
    $Thread-38准备生产一个产品......
    $$线程Thread-38 has produced new one.Now number is 14--$$
    $Thread-36准备生产一个产品......
    $$线程Thread-36 has produced new one.Now number is 15--$$
    $Thread-50准备生产一个产品......
    $$线程Thread-50 has produced new one.Now number is 16--$$
    $Thread-52准备生产一个产品......
    $$线程Thread-52 has produced new one.Now number is 17--$$
    $Thread-56准备生产一个产品......
    $$线程Thread-56 has produced new one.Now number is 18--$$
    $Thread-34准备生产一个产品......
    $$线程Thread-34 has produced new one.Now number is 19--$$
    $Thread-40准备生产一个产品......
    $$线程Thread-40 has produced new one.Now number is 20--$$
    $Thread-44准备生产一个产品......
    $$线程Thread-44 yield 
    ##线程Thread-1 has customized one.Now number is 19--##
    ##线程Thread-5 has customized one.Now number is 18--##
    ##线程Thread-11 has customized one.Now number is 17--##
    ##线程Thread-35 has customized one.Now number is 16--##
    ##线程Thread-25 has customized one.Now number is 15--##
    ##线程Thread-9 has customized one.Now number is 14--##
    ##线程Thread-13 has customized one.Now number is 13--##
    $$线程Thread-44 has produced new one.Now number is 14--$$
    ##线程Thread-15 has customized one.Now number is 13--##
    ##线程Thread-17 has customized one.Now number is 12--##
    ##线程Thread-19 has customized one.Now number is 11--##
    ##线程Thread-21 has customized one.Now number is 10--##
    ##线程Thread-23 has customized one.Now number is 9--##
    ##线程Thread-59 has customized one.Now number is 8--##
    ##线程Thread-57 has customized one.Now number is 7--##
    ##线程Thread-55 has customized one.Now number is 6--##
    ##线程Thread-53 has customized one.Now number is 5--##
    ##线程Thread-51 has customized one.Now number is 4--##
    ##线程Thread-47 has customized one.Now number is 3--##
    ##线程Thread-45 has customized one.Now number is 2--##
    ##线程Thread-41 has customized one.Now number is 1--##
    ##线程Thread-37 has customized one.Now number is 0--##
    
    
    
    
    package com.th2;
    
    
    public class TestMain {
    
    	public static void main(String[] args) {
    		TControl control=new TControl();
    		control.setSleepTime(1000);
    //		control.setMontorPrint(true);
    //		control.setMontorTime(100);
    //		
    //		control.monitor();//这里是监控的打印，因为都在控制台打印，所以很乱，注释掉
    		
    		for(int i=0;i<30;i++){
    			PThread productor=new PThread(control);
    			CThread customer=new CThread(control);
    			
    			customer.start();
    			productor.start();
    			
    		}
    		
    	}
    }
    
    
    
    
    
    排队竞争
    
    打印：
    
    
    #Thread-1准备消费一个产品~~~~~~
    #Thread-3准备消费一个产品~~~~~~
    #Thread-5准备消费一个产品~~~~~~
    #Thread-7准备消费一个产品~~~~~~
    #Thread-9准备消费一个产品~~~~~~
    #Thread-11准备消费一个产品~~~~~~
    #Thread-13准备消费一个产品~~~~~~
    $Thread-0准备生产一个产品......
    #Thread-25准备消费一个产品~~~~~~
    #Thread-23准备消费一个产品~~~~~~
    #Thread-21准备消费一个产品~~~~~~
    #Thread-19准备消费一个产品~~~~~~
    #Thread-17准备消费一个产品~~~~~~
    $$线程Thread-0 has produced new one.Now number is 1--$$
    #Thread-15准备消费一个产品~~~~~~
    ##线程Thread-15 has customized one.Now number is 0--##
    $Thread-2准备生产一个产品......
    #Thread-29准备消费一个产品~~~~~~
    #Thread-27准备消费一个产品~~~~~~
    #Thread-31准备消费一个产品~~~~~~
    $Thread-10准备生产一个产品......
    $Thread-12准备生产一个产品......
    $Thread-14准备生产一个产品......
    #Thread-33准备消费一个产品~~~~~~
    $Thread-16准备生产一个产品......
    #Thread-35准备消费一个产品~~~~~~
    $Thread-6准备生产一个产品......
    $Thread-4准备生产一个产品......
    #Thread-37准备消费一个产品~~~~~~
    $Thread-8准备生产一个产品......
    #Thread-39准备消费一个产品~~~~~~
    $Thread-20准备生产一个产品......
    $Thread-18准备生产一个产品......
    #Thread-43准备消费一个产品~~~~~~
    #Thread-41准备消费一个产品~~~~~~
    #Thread-45准备消费一个产品~~~~~~
    $Thread-24准备生产一个产品......
    #Thread-49准备消费一个产品~~~~~~
    $Thread-30准备生产一个产品......
    $Thread-58准备生产一个产品......
    $Thread-34准备生产一个产品......
    $Thread-22准备生产一个产品......
    #Thread-59准备消费一个产品~~~~~~
    $Thread-54准备生产一个产品......
    #Thread-57准备消费一个产品~~~~~~
    $Thread-48准备生产一个产品......
    $Thread-46准备生产一个产品......
    $Thread-44准备生产一个产品......
    $Thread-40准备生产一个产品......
    $Thread-38准备生产一个产品......
    $Thread-26准备生产一个产品......
    #Thread-55准备消费一个产品~~~~~~
    #Thread-53准备消费一个产品~~~~~~
    $Thread-32准备生产一个产品......
    #Thread-51准备消费一个产品~~~~~~
    $Thread-28准备生产一个产品......
    #Thread-47准备消费一个产品~~~~~~
    $Thread-36准备生产一个产品......
    $Thread-42准备生产一个产品......
    $Thread-50准备生产一个产品......
    $Thread-52准备生产一个产品......
    $Thread-56准备生产一个产品......
    $$线程Thread-56 has produced new one.Now number is 1--$$
    $$线程Thread-52 has produced new one.Now number is 2--$$
    $$线程Thread-50 has produced new one.Now number is 3--$$
    $$线程Thread-42 has produced new one.Now number is 4--$$
    $$线程Thread-36 has produced new one.Now number is 5--$$
    ##线程Thread-47 has customized one.Now number is 4--##
    $$线程Thread-28 has produced new one.Now number is 5--$$
    ##线程Thread-51 has customized one.Now number is 4--##
    $$线程Thread-32 has produced new one.Now number is 5--$$
    ##线程Thread-53 has customized one.Now number is 4--##
    ##线程Thread-55 has customized one.Now number is 3--##
    $$线程Thread-26 has produced new one.Now number is 4--$$
    $$线程Thread-38 has produced new one.Now number is 5--$$
    $$线程Thread-40 has produced new one.Now number is 6--$$
    $$线程Thread-44 has produced new one.Now number is 7--$$
    $$线程Thread-46 has produced new one.Now number is 8--$$
    $$线程Thread-48 has produced new one.Now number is 9--$$
    ##线程Thread-57 has customized one.Now number is 8--##
    $$线程Thread-54 has produced new one.Now number is 9--$$
    ##线程Thread-59 has customized one.Now number is 8--##
    $$线程Thread-22 has produced new one.Now number is 9--$$
    $$线程Thread-34 has produced new one.Now number is 10--$$
    $$线程Thread-58 has produced new one.Now number is 11--$$
    $$线程Thread-30 has produced new one.Now number is 12--$$
    ##线程Thread-49 has customized one.Now number is 11--##
    $$线程Thread-24 has produced new one.Now number is 12--$$
    ##线程Thread-45 has customized one.Now number is 11--##
    ##线程Thread-41 has customized one.Now number is 10--##
    ##线程Thread-43 has customized one.Now number is 9--##
    $$线程Thread-18 has produced new one.Now number is 10--$$
    $$线程Thread-20 has produced new one.Now number is 11--$$
    ##线程Thread-39 has customized one.Now number is 10--##
    $$线程Thread-8 has produced new one.Now number is 11--$$
    ##线程Thread-37 has customized one.Now number is 10--##
    $$线程Thread-4 has produced new one.Now number is 11--$$
    $$线程Thread-6 has produced new one.Now number is 12--$$
    ##线程Thread-35 has customized one.Now number is 11--##
    $$线程Thread-16 has produced new one.Now number is 12--$$
    ##线程Thread-33 has customized one.Now number is 11--##
    $$线程Thread-14 has produced new one.Now number is 12--$$
    $$线程Thread-12 has produced new one.Now number is 13--$$
    $$线程Thread-10 has produced new one.Now number is 14--$$
    ##线程Thread-31 has customized one.Now number is 13--##
    ##线程Thread-27 has customized one.Now number is 12--##
    ##线程Thread-29 has customized one.Now number is 11--##
    $$线程Thread-2 has produced new one.Now number is 12--$$
    ##线程Thread-3 has customized one.Now number is 11--##
    ##线程Thread-25 has customized one.Now number is 10--##
    ##线程Thread-17 has customized one.Now number is 9--##
    ##线程Thread-19 has customized one.Now number is 8--##
    ##线程Thread-21 has customized one.Now number is 7--##
    ##线程Thread-23 has customized one.Now number is 6--##
    ##线程Thread-1 has customized one.Now number is 5--##
    ##线程Thread-13 has customized one.Now number is 4--##
    ##线程Thread-11 has customized one.Now number is 3--##
    ##线程Thread-9 has customized one.Now number is 2--##
    ##线程Thread-7 has customized one.Now number is 1--##
    ##线程Thread-5 has customized one.Now number is 0--##
    
    
    运行第二次：
    
    #Thread-1准备消费一个产品~~~~~~
    #Thread-3准备消费一个产品~~~~~~
    #Thread-5准备消费一个产品~~~~~~
    $Thread-0准备生产一个产品......
    $$线程Thread-0 has produced new one.Now number is 1--$$
    $Thread-2准备生产一个产品......
    #Thread-25准备消费一个产品~~~~~~
    #Thread-23准备消费一个产品~~~~~~
    #Thread-21准备消费一个产品~~~~~~
    #Thread-19准备消费一个产品~~~~~~
    #Thread-17准备消费一个产品~~~~~~
    #Thread-15准备消费一个产品~~~~~~
    #Thread-13准备消费一个产品~~~~~~
    #Thread-11准备消费一个产品~~~~~~
    #Thread-9准备消费一个产品~~~~~~
    #Thread-7准备消费一个产品~~~~~~
    #Thread-27准备消费一个产品~~~~~~
    #Thread-29准备消费一个产品~~~~~~
    $Thread-4准备生产一个产品......
    #Thread-31准备消费一个产品~~~~~~
    #Thread-33准备消费一个产品~~~~~~
    #Thread-35准备消费一个产品~~~~~~
    #Thread-37准备消费一个产品~~~~~~
    $Thread-6准备生产一个产品......
    #Thread-39准备消费一个产品~~~~~~
    #Thread-41准备消费一个产品~~~~~~
    #Thread-43准备消费一个产品~~~~~~
    #Thread-45准备消费一个产品~~~~~~
    #Thread-47准备消费一个产品~~~~~~
    #Thread-49准备消费一个产品~~~~~~
    #Thread-51准备消费一个产品~~~~~~
    $Thread-8准备生产一个产品......
    #Thread-53准备消费一个产品~~~~~~
    #Thread-55准备消费一个产品~~~~~~
    #Thread-57准备消费一个产品~~~~~~
    $Thread-10准备生产一个产品......
    $Thread-12准备生产一个产品......
    #Thread-59准备消费一个产品~~~~~~
    $Thread-16准备生产一个产品......
    $Thread-14准备生产一个产品......
    $Thread-18准备生产一个产品......
    $Thread-20准备生产一个产品......
    $Thread-22准备生产一个产品......
    $Thread-24准备生产一个产品......
    $Thread-26准备生产一个产品......
    $Thread-28准备生产一个产品......
    $Thread-30准备生产一个产品......
    $Thread-56准备生产一个产品......
    $Thread-32准备生产一个产品......
    $Thread-58准备生产一个产品......
    $Thread-52准备生产一个产品......
    $Thread-50准备生产一个产品......
    $Thread-48准备生产一个产品......
    $Thread-46准备生产一个产品......
    $Thread-54准备生产一个产品......
    $Thread-44准备生产一个产品......
    $Thread-42准备生产一个产品......
    $Thread-40准备生产一个产品......
    $Thread-38准备生产一个产品......
    $Thread-36准备生产一个产品......
    $Thread-34准备生产一个产品......
    ##线程Thread-1 has customized one.Now number is 0--##
    $$线程Thread-34 has produced new one.Now number is 1--$$
    $$线程Thread-36 has produced new one.Now number is 2--$$
    $$线程Thread-38 has produced new one.Now number is 3--$$
    $$线程Thread-40 has produced new one.Now number is 4--$$
    $$线程Thread-42 has produced new one.Now number is 5--$$
    $$线程Thread-44 has produced new one.Now number is 6--$$
    $$线程Thread-54 has produced new one.Now number is 7--$$
    $$线程Thread-46 has produced new one.Now number is 8--$$
    $$线程Thread-48 has produced new one.Now number is 9--$$
    $$线程Thread-50 has produced new one.Now number is 10--$$
    $$线程Thread-52 has produced new one.Now number is 11--$$
    $$线程Thread-58 has produced new one.Now number is 12--$$
    $$线程Thread-32 has produced new one.Now number is 13--$$
    $$线程Thread-56 has produced new one.Now number is 14--$$
    $$线程Thread-30 has produced new one.Now number is 15--$$
    $$线程Thread-28 has produced new one.Now number is 16--$$
    $$线程Thread-26 has produced new one.Now number is 17--$$
    $$线程Thread-24 has produced new one.Now number is 18--$$
    $$线程Thread-22 has produced new one.Now number is 19--$$
    $$线程Thread-20 has produced new one.Now number is 20--$$
    ##线程Thread-59 has customized one.Now number is 19--##
    $$线程Thread-12 has produced new one.Now number is 20--$$
    ##线程Thread-57 has customized one.Now number is 19--##
    ##线程Thread-55 has customized one.Now number is 18--##
    $$线程Thread-8 has produced new one.Now number is 19--$$
    ##线程Thread-53 has customized one.Now number is 18--##
    ##线程Thread-51 has customized one.Now number is 17--##
    ##线程Thread-49 has customized one.Now number is 16--##
    ##线程Thread-47 has customized one.Now number is 15--##
    ##线程Thread-45 has customized one.Now number is 14--##
    ##线程Thread-43 has customized one.Now number is 13--##
    ##线程Thread-41 has customized one.Now number is 12--##
    ##线程Thread-39 has customized one.Now number is 11--##
    $$线程Thread-6 has produced new one.Now number is 12--$$
    ##线程Thread-37 has customized one.Now number is 11--##
    ##线程Thread-35 has customized one.Now number is 10--##
    ##线程Thread-33 has customized one.Now number is 9--##
    ##线程Thread-31 has customized one.Now number is 8--##
    $$线程Thread-4 has produced new one.Now number is 9--$$
    ##线程Thread-29 has customized one.Now number is 8--##
    ##线程Thread-27 has customized one.Now number is 7--##
    $$线程Thread-2 has produced new one.Now number is 8--$$
    ##线程Thread-7 has customized one.Now number is 7--##
    ##线程Thread-9 has customized one.Now number is 6--##
    ##线程Thread-11 has customized one.Now number is 5--##
    ##线程Thread-13 has customized one.Now number is 4--##
    ##线程Thread-15 has customized one.Now number is 3--##
    ##线程Thread-17 has customized one.Now number is 2--##
    ##线程Thread-19 has customized one.Now number is 1--##
    ##线程Thread-21 has customized one.Now number is 0--##
    $$线程Thread-10 has produced new one.Now number is 1--$$
    $$线程Thread-16 has produced new one.Now number is 2--$$
    $$线程Thread-14 has produced new one.Now number is 3--$$
    $$线程Thread-18 has produced new one.Now number is 4--$$
    ##线程Thread-3 has customized one.Now number is 3--##
    ##线程Thread-5 has customized one.Now number is 2--##
    ##线程Thread-25 has customized one.Now number is 1--##
    ##线程Thread-23 has customized one.Now number is 0--##