zoukankan      html  css  js  c++  java
  • 使用阻塞队列实现生产者和消费者问题

      BlockingQueue<E>接口定义了包括两个附加功能的队列。这两个功能是:如果从空队列中取元素或者向满队列中增加元素,则进入等待状态。BlockinQueue接口中的方法pu(e)t和take()可以使其进入无限阻塞状态,可以用这两个方法实现生产者和消费者问题,比较简单。

    代码如下:

    package com.lk.B;
    
    import java.util.Random;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    
    public class Test5 {
    	private BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(2);
    	private class Producer implements Runnable{
    
    		@Override
    		public void run() {
    			// TODO Auto-generated method stub
    			for(int i=0;i<5;i++){
    				int b = new Random().nextInt(255);
    				try {
    					queue.put(b);
    					System.out.println("向队列中加入"+b+"	队列中有"+queue.size()+"个元素");
    				} catch (InterruptedException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    		}
    		
    	}
    	
    	private class Consumer implements Runnable{
    
    		@Override
    		public void run() {
    			try {
    				Thread.sleep(100);
    			} catch (InterruptedException e1) {
    				// TODO Auto-generated catch block
    				e1.printStackTrace();
    			}
    			// TODO Auto-generated method stub
    			for(int i=0;i<5;i++){
    				int b = 0;
    				try {
    					b=queue.take();
    					System.out.println("从队列中取出"+b+"	队列中有"+queue.size()+"个元素");
    				} catch (InterruptedException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    		}
    	}
    	
    	public static void main(String[] args) {
    		Test5 test5 = new Test5();
    		Producer producer = test5.new Producer();
    		Consumer consumer = test5.new Consumer();
    		new Thread(producer).start();
    		new Thread(consumer).start();
    	}
    }
    

      运行结果:

    /*
    向队列中加入127	队列中有1个元素
    向队列中加入113	队列中有2个元素
    从队列中取出127	队列中有1个元素
    向队列中加入88	        队列中有2个元素
    从队列中取出113	队列中有1个元素
    从队列中取出88	        队列中有0个元素
    向队列中加入212	队列中有1个元素
    从队列中取出212	队列中有0个元素
    向队列中加入243	队列中有1个元素
    从队列中取出243	队列中有0个元素
    */  
    

      

  • 相关阅读:
    linux 常用命令(个人记录)
    jmeter 5.0版本更新说明(个人做个记录)
    Netdata---Linux系统性能实时监控平台部署记录
    MySQL Yum存储库 安装、升级、集群
    linux 各项配置汇总
    构建Maven项目自动下载jar包
    计算服务器的pv量算法
    性能计算公式
    jstack(查看线程)、jmap(查看内存)和jstat(性能分析)命令
    结构模式
  • 原文地址:https://www.cnblogs.com/luankun0214/p/4398821.html
Copyright © 2011-2022 走看看