java多线程之并发集合（BlockingQueue）

ゝ一纸荒年。 2022-04-22 13:36 233阅读 0赞

## 简介 ##

![20181105155604784.png][]

## 实现 ##

package com.np.ota.test.queue;
    
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.TimeUnit;
    
    public class BlockQueueTest {
    
    	public static void main(String[] args) throws InterruptedException {
    		BlockingQueue<String> queue = new LinkedBlockingQueue<String>(Integer.MAX_VALUE);
    		//queue.add("121");
    		queue.offer("122", 2, TimeUnit.SECONDS);//添加元素，添加超时时间
    		
    		//Retrieves and removes the head of this queue, or returns null if this queue is empty.
    		System.out.println(queue.poll());//获取并删除，不阻塞
    		//Retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.
    		System.out.println(queue.peek());//获取不删除，不阻塞
    		//Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
    		System.out.println(queue.take());//获取并删除，阻塞
    	}
    
    }

## 结果 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA3Mzk1NTE_size_16_color_FFFFFF_t_70][]

[20181105155604784.png]: /images/20220422/4ded125fb1e041e2bfa5bca527aa2aa6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTA3Mzk1NTE_size_16_color_FFFFFF_t_70]: /images/20220422/0978eb7f502e46b0b4dd16ca7bdd0f8d.png

发表评论取消回复

表情：

评论列表（有 0 条评论，233人围观）

还没有评论，来说两句吧...

相关阅读

相关多线程（26）BlockingQueue

是Java并发包（）中的一个接口，它扩展了Queue接口。支持两个附加操作：等待队列变为非空时取元素，和等待空间变得可用时存储元素。这使得非常适合用作生产者-消费者场景中...

迈不过友情╰/ 2024年04月24日 23:10/ 0 赞/ 72 阅读

相关 Java多线程-工具篇-BlockingQueue

[https://www.cnblogs.com/jackyuj/archive/2010/11/24/1886553.html][https_www.cnblogs.com_

喜欢ヅ旅行/ 2023年08月17日 16:44/ 0 赞/ 111 阅读

相关 [java多线程] java并发编程之BlockingQueue

前言：多线程在我们实际开发中使用比较多，因为最近也在使用BlockingQueue，所以也准备在这里总结一下，方便以后自己的查找。 BlockingQueue B

你的名字/ 2023年07月01日 05:26/ 0 赞/ 25 阅读

相关 [Java 多线程] 并发集合类

ConcurrentHashMap JDK 1.5 中的java.util.concurrent 包是对Map 的线程安全的实现，比起synchronizedMap 来，他

客官°小女子只卖身不卖艺/ 2022年09月28日 13:26/ 0 赞/ 93 阅读

相关多线程-BlockingQueue

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

雨点打透心脏的1/2处/ 2022年07月15日 00:13/ 0 赞/ 145 阅读

相关多线程-BlockingQueue

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

╰半夏微凉°/ 2022年07月15日 00:13/ 0 赞/ 144 阅读

相关【Java并发之】BlockingQueue

一、什么是BlockingQueue BlockingQueue即阻塞队列，从阻塞这个词可以看出，在某些情况下对阻塞队列的访问可能会造成阻塞。被阻塞的情况主要有如下两种：

落日映苍穹つ/ 2022年06月10日 06:39/ 0 赞/ 178 阅读

相关 java多线程之并发集合（BlockingQueue）

简介 ![20181105155604784.png][] 实现 package com.np.ota.test.queue; i

ゝ一纸荒年。/ 2022年04月22日 13:36/ 0 赞/ 234 阅读

相关 java多线程之并发集合（CopyOnWriteArrayList）

CopyOnWriteArrayList:CopyOnWriteArrayList这是一个ArrayList的线程安全的变体，其原理大概可以通俗的理解为:初始化的时候只有一个容

灰太狼/ 2022年04月22日 13:28/ 0 赞/ 218 阅读

相关 java多线程并发之旅-10-阻塞队列 BlockingQueue

Q 为什么要有阻塞队列？什么是阻塞队列优缺点适用场景实现思想+源码个人启发阻塞队列什么是阻塞队列？阻塞队列（

冷不防/ 2022年02月26日 08:30/ 0 赞/ 359 阅读