介面 java.util.concurrent.BlockingQueue
的使用

使用 BlockingQueue 的軟體套件

java.util.concurrent

在共時程式中很常用的實用工具類別。

java.util.concurrent 中 BlockingQueue 的使用

java.util.concurrent 中 BlockingQueue 的子介面

interface

BlockingDeque<E> 支持兩個附加操作的 Queue，這兩個操作是：獲取元素時等待雙端佇列變為非空(null)；存儲元素時等待雙端佇列中的空間變得可用。

實作 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。