インタフェースjava.util.concurrent.BlockingQueue
の使用
BlockingQueueを使用するパッケージ
-
java.util.concurrentでのBlockingQueueの使用
java.util.concurrentのBlockingQueueのサブインタフェース修飾子と型インタフェース説明interface
要素の取得時に両端キューが空でなくなるまで待機したり、要素の格納時に両端キュー内に空きが生じるまで待機するブロック操作を追加でサポートしたりするDeque
です。interface
コンシューマが要素を受け取るまでプロデューサが待機するBlockingQueue
。BlockingQueueを実装しているjava.util.concurrentのクラス修飾子と型クラス説明class
配列に連動する、制限付きのブロッキング・キューです。class
DelayQueue<E extends Delayed>
Delayed
要素のバインドされていない「ブロック・キュー」。この要素では、遅延が期限切れになると、要素が一般的に削除の対象になります。class
リンク・ノードに基づく、オプションで制限付きになるブロッキング両端キューです。class
リンク・ノードに基づく、オプションで制限付きになるブロッキング・キューです。class
リンク・ノードに基づく、制限なしのTransferQueue
です。class
クラスPriorityQueue
と同じ順序付けルールを使用するとともにブロッキング取得オペレーションを提供する、制限なしのブロッキング・キューです。class
各挿入オペレーションが別のスレッドによる対応する削除オペレーションを待機する必要がある(およびその逆の) ブロッキング・キューです。修飾子と型メソッド説明ScheduledThreadPoolExecutor.getQueue()
このexecutorで使用するタスク・キューを返します。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
を作成します。