インタフェースjava.util.concurrent.BlockingQueue
の使用

BlockingQueueを使用するパッケージ

パッケージ	説明
java.util.concurrent	並行プログラミングでよく使用されるユーティリティ・クラスです。

java.util.concurrentでのBlockingQueueの使用

java.util.concurrentのBlockingQueueのサブインタフェース

修飾子と型	インタフェース	説明
interface	BlockingDeque<E>	要素の取得時に両端キューが空でなくなるまで待機したり、要素の格納時に両端キュー内に空きが生じるまで待機するブロック操作を追加でサポートしたりするDequeです。
interface	TransferQueue<E>	コンシューマが要素を受け取るまでプロデューサが待機するBlockingQueue。

BlockingQueueを実装しているjava.util.concurrentのクラス

修飾子と型	クラス	説明
class	ArrayBlockingQueue<E>	配列に連動する、制限付きのブロッキング・キューです。
class	DelayQueue<E extends Delayed>	Delayed要素のバインドされていない「ブロック・キュー」。この要素では、遅延が期限切れになると、要素が一般的に削除の対象になります。
class	LinkedBlockingDeque<E>	リンク・ノードに基づく、オプションで制限付きになるブロッキング両端キューです。
class	LinkedBlockingQueue<E>	リンク・ノードに基づく、オプションで制限付きになるブロッキング・キューです。
class	LinkedTransferQueue<E>	リンク・ノードに基づく、制限なしのTransferQueueです。
class	PriorityBlockingQueue<E>	クラスPriorityQueueと同じ順序付けルールを使用するとともにブロッキング取得オペレーションを提供する、制限なしのブロッキング・キューです。
class	SynchronousQueue<E>	各挿入オペレーションが別のスレッドによる対応する削除オペレーションを待機する必要がある(およびその逆の) ブロッキング・キューです。

BlockingQueueを返すjava.util.concurrentのメソッド

修飾子と型	メソッド	説明
BlockingQueue<Runnable>	ScheduledThreadPoolExecutor.getQueue()	このexecutorで使用するタスク・キューを返します。
BlockingQueue<Runnable>	ThreadPoolExecutor.getQueue()	このexecutorで使用するタスク・キューを返します。

型BlockingQueueのパラメータを持つjava.util.concurrentのコンストラクタ

修飾子	コンストラクタ	説明
	ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue)	基本タスクの実行用に指定されたexecutorを使用し、完了キューとして指定されたキューを使用して、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を作成します。