多线程-BlockingQueue

雨点打透心脏的1/2处 2022-07-15 00:13 132阅读 0赞

好文：    http://blog.itpub.net/143526/viewspace-1060365/

package cn.stu;
    
    import java.util.concurrent.BlockingQueue;
    
    /**
     * 
    * @ClassName: Producer
    * @Description: TODO   生产者 
    * @author yb
    * @date 2016-10-26 上午9:36:13
    *
     */
    public class Producer implements Runnable{
    	
    	private BlockingQueue<String> queue; 
    	
    	
    	public Producer(BlockingQueue<String> queue){
    		this.queue = queue;
    	}
    
    	
    	@Override
    	public void run() {
    		try {
    			String temp = "mac-15寸";
    			queue.put(temp); // 如果队列满了， 就会阻塞。-------会一直卡在这里。
    			System.out.println("生产者--->开始生产："+temp);
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    		 
    	}
    	 
    }

package cn.stu;
    
    import java.util.concurrent.BlockingQueue;
    
    /**
     * 
    * @ClassName: Consumer
    * @Description: TODO  消费者 
    * @author yb
    * @date 2016-10-26 上午9:40:54
    *
     */
    public class Consumer implements Runnable{
    	
    	private BlockingQueue<String> queue; 
    	
    	public Consumer(BlockingQueue<String> queue){
    		
    		this.queue = queue;
    		
    	}
    	
    
    	@Override
    	public void run() {
    		 
    		try {
    			
    			String  temp = queue.take(); // 如果队列为null， 会阻塞当前线程。-----也就是说会一直卡在这里。
    			System.out.println("消费者-->开始消费："+temp);
    			
    		} catch (InterruptedException e) {
    			 
    			e.printStackTrace();
    		}  
    		
    		
    		
    	}
    
    }

package cn.stu;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.LinkedBlockingQueue;
    
    /***
     * 
                   队列形式，    对等待和唤醒的形式已经做了封装， 可以更好的关注更高层的东西。 
    *
     */
    public class Main {
    
    	public static void main(String[] args) {
    	 
    		LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>(2);
    		Producer  producer = new Producer(queue);
    		Consumer  consumer = new Consumer(queue);
    		
    		ExecutorService  executor = Executors.newFixedThreadPool(2);
    		
    		for(int i = 0; i<2; i++){
    			executor.submit(producer);
    			executor.submit(consumer);
    		}
    		executor.shutdown();
    	}
    
    }