インタフェース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を作成します。