接口 java.util.concurrent.BlockingQueue
的使用

使用 BlockingQueue 的软件包

java.util.concurrent

在并发编程中很常用的实用工具类。

java.util.concurrent 中 BlockingQueue 的使用

java.util.concurrent 中 BlockingQueue 的子接口

interface

BlockingDeque<E> 支持两个附加操作的 Queue，这两个操作是：获取元素时等待双端队列变为非空；存储元素时等待双端队列中的空间变得可用。

实现 BlockingQueue 的 java.util.concurrent 中的类

class	ArrayBlockingQueue<E> 一个由数组支持的有界阻塞队列。
class	DelayQueue<E extends Delayed> Delayed 元素的一个无界阻塞队列，只有在延迟期满时才能从中提取元素。
class	LinkedBlockingDeque<E> 一个基于已链接节点的、任选范围的阻塞双端队列。
class	LinkedBlockingQueue<E> 一个基于已链接节点的、范围任意的 blocking queue。
class	PriorityBlockingQueue<E> 一个无界阻塞队列，它使用与类 PriorityQueue 相同的顺序规则，并且提供了阻塞获取操作。
class	SynchronousQueue<E> 一种阻塞队列，其中每个插入操作必须等待另一个线程的对应移除操作 ，反之亦然。

返回 BlockingQueue 的 java.util.concurrent 中的方法

BlockingQueue<Runnable>	ScheduledThreadPoolExecutor.getQueue() 返回此执行程序使用的任务队列。
BlockingQueue<Runnable>	ThreadPoolExecutor.getQueue() 返回此执行程序使用的任务队列。

参数类型为 BlockingQueue 的 java.util.concurrent 中的构造方法

ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue)
使用为执行基本任务而提供的执行程序创建一个 ExecutorCompletionService，并将所提供的队列作为其完成队列。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
用给定的初始参数和默认的线程工厂及被拒绝的执行处理程序创建新的 ThreadPoolExecutor。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
用给定的初始参数和默认的线程工厂创建新的 ThreadPoolExecutor。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
用给定的初始参数和默认被拒绝的执行处理程序创建新的 ThreadPoolExecutor。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
用给定的初始参数创建新的 ThreadPoolExecutor。