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