Java.Util.Concurrent 名前空間

実装。

クラス ThreadPoolExecutorScheduledThreadPoolExecutor は、調整可能で柔軟なスレッド プールを提供します。

クラス

名前 説明
AbstractExecutorService

ExecutorService実行メソッドの既定の実装を提供します。

ArrayBlockingQueue

配列によってサポートされる境界付き BlockingQueue ブロッキング キュー。

BrokenBarrierException

スレッドが中断状態のバリアを待機しようとしたり、スレッドが待機している間に壊れた状態になったりすると、例外がスローされます。

CancellationException

タスクが取り消されたため、 FutureTaskなどの値生成タスクの結果を取得できないことを示す例外。

CompletableFuture

明示的に完了し (値と状態を設定する)、Futureとして使用できるCompletionStage。その完了時にトリガーされる依存関数とアクションをサポートします。

CompletionException

結果またはタスクの完了中にエラーまたはその他の例外が発生した場合にスローされる例外。

ConcurrentHashMap

取得の完全なコンカレンシーと、更新プログラムの高いコンカレンシーをサポートするハッシュ テーブル。

ConcurrentLinkedDeque

リンクされたノードに基づく無制限の同時実行 Deque deque。

ConcurrentLinkedQueue

リンクされたノードに基づく、無制限のスレッド セーフなキュー キュー。

ConcurrentSkipListMap

スケーラブルな同時実行 ConcurrentNavigableMap 実装。

CopyOnWriteArrayList

基になる配列の新しいコピーを作成することによって、すべての変更操作 (java.util.ArrayListaddなど) が実装されるsetのスレッド セーフなバリアント。

CopyOnWriteArraySet

すべての操作に内部Setを使用するCopyOnWriteArrayList

CountDownLatch

1 つ以上のスレッドが、他のスレッドで実行されている一連の操作が完了するまで待機できるようにする同期支援。

CountedCompleter

トリガーされたときに完了アクションが実行され、保留中のアクションが残っていない ForkJoinTask

CyclicBarrier

一連のスレッドが互いに共通のバリア ポイントに到達するまで待機できるようにする同期支援。

DelayQueue

Delayed要素の無制限の BlockingQueue ブロック キュー。通常、要素は遅延の有効期限が切れたときに削除の対象になります。

Exchanger

スレッドがペア内の要素をペアにしてスワップできる同期ポイント。

ExecutionException

例外をスローすることによって中止されたタスクの結果を取得しようとしたときにスローされる例外。

ExecutorCompletionService

指定されたCompletionServiceを使用してタスクを実行するExecutor

Executors

このパッケージで定義されている ExecutorExecutorServiceScheduledExecutorServiceThreadFactory、および Callable クラスのファクトリ メソッドとユーティリティ メソッド。

Flow

Publisher Publishersが 1 つ以上のSubscriber Subscribersによって消費される項目を生成するフロー制御コンポーネントを確立するための相互に関連するインターフェイスと静的メソッド。各コンポーネントは、Subscription Subscriptionによって管理されます。

ForkJoinPool

ExecutorServiceを実行するためのForkJoinTask

ForkJoinTask

ForkJoinPool内で実行されるタスクの抽象基本クラス。

ForkJoinWorkerThread

ForkJoinPoolを実行するForkJoinTaskによって管理されるスレッド。

FutureTask

キャンセル可能な非同期計算。

IBlockingDequeExtensions

実装。

クラス ThreadPoolExecutorScheduledThreadPoolExecutor は、調整可能で柔軟なスレッド プールを提供します。

IBlockingQueueExtensions

実装。

クラス ThreadPoolExecutorScheduledThreadPoolExecutor は、調整可能で柔軟なスレッド プールを提供します。

IExecutorServiceExtensions

実装。

クラス ThreadPoolExecutorScheduledThreadPoolExecutor は、調整可能で柔軟なスレッド プールを提供します。

IFuture.State

計算状態を表します。

IFutureExtensions

実装。

クラス ThreadPoolExecutorScheduledThreadPoolExecutor は、調整可能で柔軟なスレッド プールを提供します。

LinkedBlockingDeque

リンクされたノードに基づく、必要に応じてバインドされた BlockingDeque ブロッキング deque。

LinkedBlockingQueue

リンクされたノードに基づく、必要に応じてバインドされた BlockingQueue ブロック キュー。

LinkedTransferQueue

リンクされたノードに基づく無制限の TransferQueue

Phaser

再利用可能な同期バリア。機能が CyclicBarrierCountDownLatch に似ていますが、より柔軟な使用をサポートします。

PriorityBlockingQueue

クラス PriorityQueue と同じ順序付け規則を使用し、ブロッキング取得操作を提供する無制限の BlockingQueue ブロック キュー。

RecursiveAction

再帰的な結果のない ForkJoinTask

RecursiveTask

再帰的な結果を含む ForkJoinTask

RejectedExecutionException

タスクの実行を受け入れることができない場合に、 Executor によってスローされる例外。

ScheduledThreadPoolExecutor

特定の遅延後に実行するコマンド、または定期的に実行するコマンドをさらにスケジュールできる ThreadPoolExecutor

Semaphore

カウント セマフォ。

SubmissionPublisher

現在のサブスクライバーに送信された (null 以外の) 項目を閉じるまで非同期的に発行する Flow.Publisher

SynchronousQueue

各挿入操作が別のスレッドによる対応する削除操作を待機する必要がある BlockingQueue ブロック キュー。その逆も同様です。

ThreadLocalRandom

現在のスレッドに分離された乱数ジェネレーター (ピリオド 2<up>64</sup>)。

ThreadPoolExecutor

複数のプールされたスレッドのいずれかを使用して送信された各タスクを実行する ExecutorService 。通常は、 Executors ファクトリ メソッドを使用して構成されます。

ThreadPoolExecutor.AbortPolicy

RejectedExecutionExceptionをスローする拒否されたタスクのハンドラー。

ThreadPoolExecutor.CallerRunsPolicy

executor がシャットダウンされていない限り、 execute メソッドの呼び出し元スレッドで拒否されたタスクを直接実行する拒否されたタスクのハンドラー。その場合、タスクは破棄されます。

ThreadPoolExecutor.DiscardOldestPolicy

最も古い未処理の要求を破棄し、executor がシャットダウンされない限り execute再試行する拒否されたタスクのハンドラー。その場合、タスクは破棄されます。

ThreadPoolExecutor.DiscardPolicy

拒否されたタスクを自動的に破棄する拒否されたタスクのハンドラー。

TimeoutException

ブロック操作がタイムアウトしたときにスローされる例外。

TimeUnit

TimeUnitは、特定の単位の粒度での期間を表し、単位間で変換し、これらの単位でタイミング操作と遅延操作を実行するユーティリティ メソッドを提供します。

インターフェイス

名前 説明
CompletableFuture.IAsynchronousCompletionTask

async メソッドによって生成される非同期タスクを識別するマーカー インターフェイス。

Flow.IProcessor

サブスクライバーとPublisherの両方として機能するコンポーネント。

Flow.IPublisher

サブスクライバーが受信した項目 (および関連するコントロール メッセージ) のプロデューサー。

Flow.ISubscriber

メッセージの受信者。

Flow.ISubscription

PublisherSubscriberをリンクするメッセージ コントロール。

ForkJoinPool.IForkJoinWorkerThreadFactory

新しい ForkJoinWorkerThreadを作成するためのファクトリ。

ForkJoinPool.IManagedBlocker

ForkJoinPoolで実行されているタスクのマネージド 並列処理を拡張するためのインターフェイス。

IBlockingDeque

要素の取得時に deque が空でないのを待機し、要素を格納するときに deque 内の領域が使用可能になるのを待つブロック操作をさらにサポートする Deque

IBlockingQueue

要素の取得時にキューが空でない状態になるのを待機し、要素を格納するときにキュー内の領域が使用可能になるのを待つ操作をさらにサポートする Queue

ICallable

結果を返し、例外をスローする可能性があるタスク。

ICompletionService

新しい非同期タスクの生成と、完了したタスクの結果の使用を切り離すサービス。

ICompletionStage

別の CompletionStage が完了したときにアクションを実行するか、値を計算する非同期計算のステージ。

IConcurrentMap

スレッドの安全性と原子性の保証を提供する Map

IDelayed

特定の遅延後に処理する必要があるオブジェクトをマークするためのミックスイン スタイル インターフェイス。

IExecutor

送信された Runnable タスクを実行するオブジェクト。

IExecutorService

終了を管理するメソッドと、1 つ以上の非同期タスクの進行状況を追跡するためのExecutorを生成できるメソッドを提供するFuture

IFuture

Futureは、非同期計算の結果を表します。

IRejectedExecutionHandler

ThreadPoolExecutorで実行できないタスクのハンドラー。

IRunnableFuture

Future である Runnable

IRunnableScheduledFuture

ScheduledFuture である Runnable

IScheduledExecutorService

特定の遅延後に実行するコマンド、または定期的に実行するようにコマンドをスケジュールできる ExecutorService

IScheduledFuture

取り消すことができる遅延結果を示すアクション。

IThreadFactory

必要に応じて新しいスレッドを作成するオブジェクト。

ITransferQueue

プロデューサーがコンシューマーが要素を受け取るのを待機できる BlockingQueue