生产者--消费者模型（线程锁方式）

傷城~ 2022-08-25 15:46 159阅读 0赞

package com.type2;
    
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    /**
     * 线程锁
     * 
     * @author lushuaiyin
     *
     */
    public class TControl {
    	
    	private int poolSize=20;//线程池大小
    	private int numberNow=0;//当前线程数
    	private int sleepTime=500;//线程在排队时刷新时间
    	
    	
    	private final Lock lock = new ReentrantLock();
        private final Condition to_produce = lock.newCondition();
        private final Condition to_customize = lock.newCondition();
        
    	/**
    	 * 生产
    	 */
    	public void produce(Thread th){
    		lock.lock();//获取锁
    		
    		while(this.numberNow>=20){
    			try{
    				to_produce.await();//生产条件不满足，上锁，等待
    				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+"--$$");
    		
    		to_customize.signal();//刚完成一次生产，通知消费条件已经满足，可以进行消费
    		lock.unlock();//释放锁
    	}
    	
    	/**
    	 * 消费
    	 */
    	public void Customize(Thread th){
    		lock.lock();//获取锁
    		
    		while(this.numberNow<=0){
    			try{
    				to_customize.await();//消费条件不满足，上锁等待
    				Thread.sleep(sleepTime);
    			}catch(Exception e){
    				e.printStackTrace();
    			}
    		}// end while
    		
    		this.numberNow--;
    		System.out.println("##线程"+th.getName()+" has customized one.Now number is "+numberNow+"--##");
    		
    		to_produce.signal();//刚完成一次消费，通知生产条件已经满足可以进行生产
    		lock.unlock();//释放锁
    	}
    	
    	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;
    	}
    
    }

package com.type2;
    
    /**
     * 
     * @author lushuaiyin
     *
     */
    public class PThread extends Thread{
    	
    	private TControl control;//线程池资源控制
    	public PThread(TControl control){
    		this.control=control;
    	}
    	
    	@Override
    	public void run() {
    		System.out.println("$"+this.getName()+"准备生产一个产品......");
    		this.getControl().produce(this);
    	
    	}
    	
    	public TControl getControl() {
    		return control;
    	}
    }

package com.type2;
    
    /**
     * 
     * @author lushuaiyin
     *
     */
    public class CThread extends Thread{
    	
    	private TControl control;//线程池资源控制
    	public CThread(TControl control){
    		this.control=control;
    	}
    	
    	@Override
    	public void run() {
    		System.out.println("#"+this.getName()+"准备消费一个产品~~~~~~");
    		this.getControl().Customize(this);
    	
    	}
    	
    	public TControl getControl() {
    		return control;
    	}
    }

package com.type2;
    
    
    public class TestMain {
    
    	public static void main(String[] args) {
    		TControl control=new TControl();
    //		control.setSleepTime(100);
    		
    		for(int i=0;i<30;i++){
    			PThread productor=new PThread(control);
    			CThread customer=new CThread(control);
    			
    			productor.start();
    			customer.start();
    		}
    		
    	}
    }

打印：

刷新时间为500时打印：
    
    Thread-0准备生产一个产品......
    Produced new one.Now number is 1
    Thread-0完成生产一个产品!
    #Thread-1准备消费一个产品~~~~~~
    Customized one.Now number is 0
    #Thread-1完成消费一个产品#
    #Thread-3准备消费一个产品~~~~~~
    #Thread-5准备消费一个产品~~~~~~
    Thread-4准备生产一个产品......
    #Thread-7准备消费一个产品~~~~~~
    Produced new one.Now number is 1
    Thread-4完成生产一个产品!
    Thread-2准备生产一个产品......
    #Thread-9准备消费一个产品~~~~~~
    #Thread-11准备消费一个产品~~~~~~
    #Thread-13准备消费一个产品~~~~~~
    Thread-8准备生产一个产品......
    Thread-10准备生产一个产品......
    Thread-6准备生产一个产品......
    Thread-12准备生产一个产品......
    #Thread-15准备消费一个产品~~~~~~
    Thread-14准备生产一个产品......
    Thread-16准备生产一个产品......
    #Thread-17准备消费一个产品~~~~~~
    #Thread-19准备消费一个产品~~~~~~
    #Thread-21准备消费一个产品~~~~~~
    Thread-18准备生产一个产品......
    #Thread-23准备消费一个产品~~~~~~
    Thread-20准备生产一个产品......
    #Thread-25准备消费一个产品~~~~~~
    Thread-24准备生产一个产品......
    Thread-22准备生产一个产品......
    #Thread-31准备消费一个产品~~~~~~
    #Thread-29准备消费一个产品~~~~~~
    Thread-28准备生产一个产品......
    #Thread-27准备消费一个产品~~~~~~
    Thread-32准备生产一个产品......
    #Thread-33准备消费一个产品~~~~~~
    Thread-34准备生产一个产品......
    Thread-30准备生产一个产品......
    #Thread-37准备消费一个产品~~~~~~
    #Thread-35准备消费一个产品~~~~~~
    Thread-36准备生产一个产品......
    Thread-26准备生产一个产品......
    Thread-38准备生产一个产品......
    #Thread-39准备消费一个产品~~~~~~
    #Thread-41准备消费一个产品~~~~~~
    Thread-40准备生产一个产品......
    Thread-42准备生产一个产品......
    #Thread-43准备消费一个产品~~~~~~
    Thread-44准备生产一个产品......
    #Thread-45准备消费一个产品~~~~~~
    Thread-46准备生产一个产品......
    #Thread-59准备消费一个产品~~~~~~
    #Thread-47准备消费一个产品~~~~~~
    Thread-58准备生产一个产品......
    Thread-56准备生产一个产品......
    Thread-54准备生产一个产品......
    #Thread-57准备消费一个产品~~~~~~
    #Thread-55准备消费一个产品~~~~~~
    Thread-52准备生产一个产品......
    Thread-50准备生产一个产品......
    Thread-48准备生产一个产品......
    #Thread-53准备消费一个产品~~~~~~
    #Thread-51准备消费一个产品~~~~~~
    #Thread-49准备消费一个产品~~~~~~
    Customized one.Now number is 0
    #Thread-3完成消费一个产品#
    Produced new one.Now number is 1
    Thread-48完成生产一个产品!
    Produced new one.Now number is 2
    Thread-50完成生产一个产品!
    Produced new one.Now number is 3
    Customized one.Now number is 2
    #Thread-55完成消费一个产品#
    Customized one.Now number is 1
    #Thread-57完成消费一个产品#
    Thread-52完成生产一个产品!
    Produced new one.Now number is 2
    Thread-54完成生产一个产品!
    Produced new one.Now number is 3
    Thread-56完成生产一个产品!
    Produced new one.Now number is 4
    Thread-58完成生产一个产品!
    Customized one.Now number is 3
    #Thread-47完成消费一个产品#
    Customized one.Now number is 2
    #Thread-59完成消费一个产品#
    Produced new one.Now number is 3
    Thread-46完成生产一个产品!
    Customized one.Now number is 2
    #Thread-45完成消费一个产品#
    Produced new one.Now number is 3
    Thread-44完成生产一个产品!
    Customized one.Now number is 2
    #Thread-43完成消费一个产品#
    Produced new one.Now number is 3
    Thread-42完成生产一个产品!
    Produced new one.Now number is 4
    Customized one.Now number is 3
    Thread-40完成生产一个产品!
    Customized one.Now number is 2
    #Thread-39完成消费一个产品#
    #Thread-41完成消费一个产品#
    Produced new one.Now number is 3
    Thread-38完成生产一个产品!
    Produced new one.Now number is 4
    Thread-36完成生产一个产品!
    Produced new one.Now number is 5
    Thread-26完成生产一个产品!
    Produced new one.Now number is 6
    Thread-30完成生产一个产品!
    Customized one.Now number is 5
    #Thread-35完成消费一个产品#
    Customized one.Now number is 4
    #Thread-37完成消费一个产品#
    Produced new one.Now number is 5
    Thread-34完成生产一个产品!
    Customized one.Now number is 4
    #Thread-33完成消费一个产品#
    Produced new one.Now number is 5
    Thread-32完成生产一个产品!
    Customized one.Now number is 4
    #Thread-27完成消费一个产品#
    Produced new one.Now number is 5
    Thread-28完成生产一个产品!
    Customized one.Now number is 4
    #Thread-29完成消费一个产品#
    Customized one.Now number is 3
    #Thread-31完成消费一个产品#
    Produced new one.Now number is 4
    Thread-22完成生产一个产品!
    Produced new one.Now number is 5
    Thread-24完成生产一个产品!
    Customized one.Now number is 4
    #Thread-25完成消费一个产品#
    Produced new one.Now number is 5
    Thread-20完成生产一个产品!
    Customized one.Now number is 4
    #Thread-23完成消费一个产品#
    Produced new one.Now number is 5
    Thread-18完成生产一个产品!
    Customized one.Now number is 4
    #Thread-21完成消费一个产品#
    Customized one.Now number is 3
    #Thread-19完成消费一个产品#
    Customized one.Now number is 2
    #Thread-17完成消费一个产品#
    Produced new one.Now number is 3
    Thread-16完成生产一个产品!
    Produced new one.Now number is 4
    Thread-14完成生产一个产品!
    Customized one.Now number is 3
    #Thread-15完成消费一个产品#
    Produced new one.Now number is 4
    Produced new one.Now number is 5
    Thread-6完成生产一个产品!
    Thread-12完成生产一个产品!
    Produced new one.Now number is 6
    Thread-10完成生产一个产品!
    Produced new one.Now number is 7
    Thread-8完成生产一个产品!
    Customized one.Now number is 6
    #Thread-13完成消费一个产品#
    Customized one.Now number is 5
    #Thread-11完成消费一个产品#
    Customized one.Now number is 4
    #Thread-9完成消费一个产品#
    Produced new one.Now number is 5
    Thread-2完成生产一个产品!
    Customized one.Now number is 4
    #Thread-7完成消费一个产品#
    Customized one.Now number is 3
    #Thread-53完成消费一个产品#
    Customized one.Now number is 2
    #Thread-51完成消费一个产品#
    Customized one.Now number is 1
    #Thread-49完成消费一个产品#
    Customized one.Now number is 0
    #Thread-5完成消费一个产品#
    
    
    刷新时间为15000时打印：
    
    Thread-0准备生产一个产品......
    Produced new one.Now number is 1
    Thread-0完成生产一个产品!
    Thread-2准备生产一个产品......
    Produced new one.Now number is 2
    Thread-2完成生产一个产品!
    Thread-4准备生产一个产品......
    Produced new one.Now number is 3
    Thread-4完成生产一个产品!
    Thread-6准备生产一个产品......
    Produced new one.Now number is 4
    Thread-6完成生产一个产品!
    Thread-8准备生产一个产品......
    Produced new one.Now number is 5
    Thread-8完成生产一个产品!
    Thread-10准备生产一个产品......
    Produced new one.Now number is 6
    Thread-10完成生产一个产品!
    Thread-12准备生产一个产品......
    Produced new one.Now number is 7
    Thread-12完成生产一个产品!
    Thread-14准备生产一个产品......
    Produced new one.Now number is 8
    Thread-14完成生产一个产品!
    Thread-16准备生产一个产品......
    Produced new one.Now number is 9
    Thread-16完成生产一个产品!
    Thread-18准备生产一个产品......
    Produced new one.Now number is 10
    Thread-18完成生产一个产品!
    Thread-20准备生产一个产品......
    Produced new one.Now number is 11
    Thread-20完成生产一个产品!
    Thread-22准备生产一个产品......
    Produced new one.Now number is 12
    Thread-22完成生产一个产品!
    Thread-24准备生产一个产品......
    Produced new one.Now number is 13
    Thread-24完成生产一个产品!
    Thread-28准备生产一个产品......
    Produced new one.Now number is 14
    Thread-28完成生产一个产品!
    Thread-26准备生产一个产品......
    Produced new one.Now number is 15
    Thread-26完成生产一个产品!
    #Thread-1准备消费一个产品~~~~~~
    Customized one.Now number is 14
    #Thread-1完成消费一个产品#
    #Thread-3准备消费一个产品~~~~~~
    Customized one.Now number is 13
    Thread-58准备生产一个产品......
    #Thread-13准备消费一个产品~~~~~~
    #Thread-15准备消费一个产品~~~~~~
    #Thread-39准备消费一个产品~~~~~~
    Thread-56准备生产一个产品......
    #Thread-37准备消费一个产品~~~~~~
    Thread-54准备生产一个产品......
    Thread-52准备生产一个产品......
    #Thread-35准备消费一个产品~~~~~~
    Thread-50准备生产一个产品......
    #Thread-33准备消费一个产品~~~~~~
    Thread-48准备生产一个产品......
    Thread-46准备生产一个产品......
    #Thread-29准备消费一个产品~~~~~~
    #Thread-27准备消费一个产品~~~~~~
    Thread-44准备生产一个产品......
    #Thread-25准备消费一个产品~~~~~~
    Thread-40准备生产一个产品......
    #Thread-23准备消费一个产品~~~~~~
    Thread-38准备生产一个产品......
    #Thread-21准备消费一个产品~~~~~~
    Thread-36准备生产一个产品......
    #Thread-9准备消费一个产品~~~~~~
    Thread-34准备生产一个产品......
    #Thread-7准备消费一个产品~~~~~~
    Thread-32准备生产一个产品......
    #Thread-5准备消费一个产品~~~~~~
    Thread-30准备生产一个产品......
    #Thread-19准备消费一个产品~~~~~~
    #Thread-43准备消费一个产品~~~~~~
    #Thread-45准备消费一个产品~~~~~~
    #Thread-47准备消费一个产品~~~~~~
    #Thread-49准备消费一个产品~~~~~~
    #Thread-51准备消费一个产品~~~~~~
    #Thread-53准备消费一个产品~~~~~~
    #Thread-55准备消费一个产品~~~~~~
    #Thread-57准备消费一个产品~~~~~~
    #Thread-31准备消费一个产品~~~~~~
    #Thread-59准备消费一个产品~~~~~~
    #Thread-17准备消费一个产品~~~~~~
    Thread-42准备生产一个产品......
    #Thread-41准备消费一个产品~~~~~~
    #Thread-3完成消费一个产品#
    Produced new one.Now number is 14
    Thread-58完成生产一个产品!
    #Thread-11准备消费一个产品~~~~~~
    Customized one.Now number is 13
    #Thread-11完成消费一个产品#
    Customized one.Now number is 12
    #Thread-41完成消费一个产品#
    Produced new one.Now number is 13
    Thread-42完成生产一个产品!
    Customized one.Now number is 12
    #Thread-17完成消费一个产品#
    Customized one.Now number is 11
    #Thread-59完成消费一个产品#
    Customized one.Now number is 10
    #Thread-31完成消费一个产品#
    Customized one.Now number is 9
    #Thread-57完成消费一个产品#
    Customized one.Now number is 8
    #Thread-55完成消费一个产品#
    Customized one.Now number is 7
    #Thread-53完成消费一个产品#
    Customized one.Now number is 6
    #Thread-51完成消费一个产品#
    Customized one.Now number is 5
    #Thread-49完成消费一个产品#
    Customized one.Now number is 4
    #Thread-47完成消费一个产品#
    Customized one.Now number is 3
    #Thread-45完成消费一个产品#
    Customized one.Now number is 2
    Customized one.Now number is 1
    #Thread-43完成消费一个产品#
    Produced new one.Now number is 2
    #Thread-19完成消费一个产品#
    Thread-30完成生产一个产品!
    Customized one.Now number is 1
    #Thread-5完成消费一个产品#
    Produced new one.Now number is 2
    Thread-32完成生产一个产品!
    Customized one.Now number is 1
    #Thread-7完成消费一个产品#
    Produced new one.Now number is 2
    Thread-34完成生产一个产品!
    Customized one.Now number is 1
    #Thread-9完成消费一个产品#
    Produced new one.Now number is 2
    Thread-36完成生产一个产品!
    Customized one.Now number is 1
    #Thread-21完成消费一个产品#
    Produced new one.Now number is 2
    Thread-38完成生产一个产品!
    Customized one.Now number is 1
    #Thread-23完成消费一个产品#
    Produced new one.Now number is 2
    Thread-40完成生产一个产品!
    Customized one.Now number is 1
    #Thread-25完成消费一个产品#
    Produced new one.Now number is 2
    Thread-44完成生产一个产品!
    Customized one.Now number is 1
    #Thread-27完成消费一个产品#
    Customized one.Now number is 0
    #Thread-29完成消费一个产品#
    Produced new one.Now number is 1
    Thread-46完成生产一个产品!
    Produced new one.Now number is 2
    Thread-48完成生产一个产品!
    Customized one.Now number is 1
    #Thread-33完成消费一个产品#
    Produced new one.Now number is 2
    Thread-50完成生产一个产品!
    Customized one.Now number is 1
    #Thread-35完成消费一个产品#
    Produced new one.Now number is 2
    Thread-52完成生产一个产品!
    Produced new one.Now number is 3
    Thread-54完成生产一个产品!
    Customized one.Now number is 2
    #Thread-37完成消费一个产品#
    Produced new one.Now number is 3
    Thread-56完成生产一个产品!
    Customized one.Now number is 2
    #Thread-39完成消费一个产品#
    Customized one.Now number is 1
    #Thread-15完成消费一个产品#
    Customized one.Now number is 0
    #Thread-13完成消费一个产品#
    
    
    从线程刷新时间可以看出，当某个线程生产者或消费者行动阻塞时，
    我们让这个线程阻塞的同时并挂起一段时间，这个时间越短流水线就更流畅或者说更紧凑。
    （一旦可以生产或者消费，马上就行动）。
    
    这个时间越长，流水线更连贯但是更容易出现阻塞的情况。
    （一旦阻塞，那么阻塞的一方就休息一段时间再开工，这时另一方已经生产或者消费
    足够多的产品了）