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