博客
关于我
强烈建议你试试无所不能的chatGPT，快点击我
JAVA并发编程-阻塞队列和阻塞栈
阅读量：2811 次
发布时间：2019-05-13

本文共 2573 字，大约阅读时间需要 8 分钟。

转载请注明出处：

阻塞队列

    阻塞队列是5并发新特性中的内容，阻塞队列的接口是.util.concurrent.BlockingQueue，它有多个实现类：ArrayBlockingQueue、DelayQueue、LinkedBlockingQueue、PriorityBlockingQueue、SynchronousQueue等，用法大同小异，具体可查看JDK文档，这里简单举例看下ArrayBlockingQueue，它实现了一个有界队列，当队列满时，便会阻塞等待，直到有元素出队，后续的元素才可以被加入队列。

    看下面的例子：

[java]
  1. import java.util.concurrent.BlockingQueue;   
  2. import java.util.concurrent.ArrayBlockingQueue;   
  3.   
  4. public class BlockingQueueTest{   
  5.         public static void main(String[] args) throws InterruptedException {   
  6.                 BlockingQueue<String> bqueue = new ArrayBlockingQueue<String>(20);   
  7.                 for (int i = 0; i < 30; i++) {   
  8.                         //将指定元素添加到此队列中   
  9.                         bqueue.put("加入元素" + i);   
  10.                         System.out.println("向阻塞队列中添加了元素:" + i);   
  11.                 }   
  12.                 System.out.println("程序到此运行结束，即将退出----");   
  13.         }   
  14. }  
    输出结果如下：

    从执行结果中可以看出，由于队列中元素的数量限制在了20个，因此添加20个元素后，其他元素便在队列外阻塞等待，程序并没有终止。

    如果队列已满后，我们将队首元素移出，并可以继续向阻塞队列中添加元素，修改代码如下：

[java]
  1. import java.util.concurrent.BlockingQueue;   
  2. import java.util.concurrent.ArrayBlockingQueue;   
  3.   
  4. public class BlockingQueueTest{   
  5.         public static void main(String[] args) throws InterruptedException {   
  6.                 BlockingQueue<String> bqueue = new ArrayBlockingQueue<String>(20);   
  7.                 for (int i = 0; i < 30; i++) {   
  8.                         //将指定元素添加到此队列中   
  9.                         bqueue.put("" + i);   
  10.                         System.out.println("向阻塞队列中添加了元素:" + i);   
  11.                         if(i > 18){  
  12.                             //从队列中获取队头元素，并将其移出队列  
  13.                             System.out.println("从阻塞队列中移除元素：" + bqueue.take());  
  14.                         }  
  15.                 }   
  16.                 System.out.println("程序到此运行结束，即将退出----");   
  17.         }   
  18. }  
    执行结果如下：
    从结果中可以看出，当添加了第20个元素后，我们从队首移出一个元素，这样便可以继续向队列中添加元素，之后每添加一个元素，便从将队首元素移除，这样程序便可以执行结束。

     

阻塞栈

   阻塞栈与阻塞队列相似，只是它是Java 6中加入的新特性，阻塞栈的接口java.util.concurrent.BlockingDeque也有很多实现类，使用方法也比较相似，具体查看JDK文档。

    下面同样给出一个简单的例子：

[java]
  1. import java.util.concurrent.BlockingDeque;   
  2. import java.util.concurrent.LinkedBlockingDeque;   
  3.   
  4. public class BlockingDequeTest {   
  5.     public static void main(String[] args) throws InterruptedException {   
  6.             BlockingDeque<String> bDeque = new LinkedBlockingDeque<String>(20);   
  7.             for (int i = 0; i < 30; i++) {   
  8.                 //将指定元素添加到此阻塞栈中  
  9.                 bDeque.putFirst("" + i);   
  10.                 System.out.println("向阻塞栈中添加了元素:" + i);   
  11.             }   
  12.             System.out.println("程序到此运行结束，即将退出----");   
  13.     }   
  14. }  
    执行结果如下：

    程序依然会阻塞等待，我们改为如下代码：

[java]
  1. import java.util.concurrent.BlockingDeque;   
  2. import java.util.concurrent.LinkedBlockingDeque;   
  3.   
  4. public class BlockingDequeTest {   
  5.     public static void main(String[] args) throws InterruptedException {   
  6.             BlockingDeque<String> bDeque = new LinkedBlockingDeque<String>(20);   
  7.             for (int i = 0; i < 30; i++) {   
  8.                 //将指定元素添加到此阻塞栈中  
  9.                 bDeque.putFirst("" + i);   
  10.                 System.out.println("向阻塞栈中添加了元素:" + i);   
  11.                 if(i > 18){  
  12.                     //从阻塞栈中取出栈顶元素，并将其移出  
  13.                     System.out.println("从阻塞栈中移出了元素：" + bDeque.pollFirst());  
  14.                 }  
  15.             }   
  16.             System.out.println("程序到此运行结束，即将退出----");   
  17.     }   
  18. }  
    执行结果如下：

    从结果中可以看出，当添加了第20个元素后，我们从将栈顶元素移处，这样便可以继续向栈中添加元素，之后每添加一个元素，便将栈顶元素移出，这样程序便可以执行结束。

你可能感兴趣的文章
内核的进程管理与调度
查看>>
Linux环境下修改或指定python的默认版本
查看>>
linux 安装Anaconda/Miniconda以后无法识别conda命令
查看>>
linux
查看>>
caffe/ windows 10 /Can't parse message of type "caffe.NetParameter" because it is missing required
查看>>
matplotlib/plt 函数savefig保存的图像有空白
查看>>
Machine learning Year阅读笔记
查看>>
windows10 + caffe 配置CUDA10.0
查看>>
python/matplotlib绘制统计直方图
查看>>
linxu/torch/pytorch会自动安装 cuda
查看>>
详解微信小程序胶囊按钮返回|首页自定义导航栏功能
查看>>
微信小程序修改右上角胶囊背景色 信号色
查看>>
微信小程序触摸滑动事件
查看>>
python技术点
查看>>
安装vue搭建移端项目1
查看>>
px pt rpx rem
查看>>
微擎开发001
查看>>
php打印错误信息
查看>>
h5下载预览pdf,excel
查看>>
js视频播放器DPlayer，video.js
查看>>
喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！-- 愿君每日到此一游！
当前时间: 2024-09-03 05:18:59   当前IP: 3.137.178.228   联系邮箱:javaeecc@qq.com     Copyright © 2020 - 2022 baihongyu.com 京ICP备2021015314号-2
强烈建议你试试无所不能的CHAT-GPT，快点击我
强烈建议你试试无所不能的CHAT-GPT，快点击我