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