Java基于BlockingQueue阻塞队列实现生产者消费者模型

悠悠 2023-01-07 10:18 214阅读 0赞

测试用生产者模型：

package domain;
    
    import java.util.concurrent.BlockingQueue;
    
    /**
     * 生产者模型
     * 
     * @author WanAkiko
     * 
     */
    public class EProductor implements Runnable {
    
    	private BlockingQueue<String> queue;
    	int count = 1;
    
    	public EProductor(BlockingQueue<String> queue) {
    		super();
    		this.queue = queue;
    	}
    
    	@Override
    	public void run() {
    		while (true) {
    			String msg = "产品序列" + (count++);
    			try {
    				Thread.sleep(1000);
    				queue.add(msg);
    				System.out.println("生产者线程：" + msg);
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    	}
    
    }

测试用消费者模型：

package domain;
    
    import java.util.concurrent.BlockingQueue;
    
    /**
     * 消费者模型
     * 
     * @author WanAkiko
     * 
     */
    public class EConsumer implements Runnable {
    
    	private BlockingQueue<String> queue;
    
    	public EConsumer(BlockingQueue<String> queue) {
    		super();
    		this.queue = queue;
    	}
    
    	@Override
    	public void run() {
    		while (true) {
    			try {
    				Thread.sleep(1000);
    				String msg = queue.take();
    				System.out.println("消费者线程：" + msg);
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    	}
    
    }

模型测试：

package client;
    
    import java.util.concurrent.ArrayBlockingQueue;
    
    import domain.EConsumer;
    import domain.EProductor;
    
    public class PC03Test {
    
    	public static void main(String[] args) {
    		
    		ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
    		new Thread(new EProductor(queue)).start();
    		new Thread(new EConsumer(queue)).start();
    		
    	}
    	
    }

运行示例：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70]: /images/20221119/b1b67e20f759478c8edd488913585df1.png