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

BlockingQueue を使用しているパッケージ

java.util.concurrent

並行プログラミングでよく使用されるユーティリティークラスです。

java.util.concurrent での BlockingQueue の使用

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

interface

BlockingDeque<E> 要素の取得時に両端キューが空でなくなるまで待機したり、要素の格納時に両端キュー内に空きが生じるまで待機するブロック操作を追加でサポートしたりする Deque です。

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

class	ArrayBlockingQueue<E> 配列に連動するバウンド形式のブロッキングキューです。
class	DelayQueue<E extends Delayed> Delayed 要素のアンバウンド形式のブロッキングキューで、遅延時間が経過後にのみ、要素を取得できます。
class	LinkedBlockingDeque<E> リンクノードに基づく、任意のバウンド形式のブロッキング両端キューです。
class	LinkedBlockingQueue<E> リンクノードに基づく、任意のバウンド形式のブロッキングキューです。
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 を作成します。