Java.Util.Concurrent 命名空間

實作。

ThreadPoolExecutor類別並ScheduledThreadPoolExecutor提供可調校且彈性的執行緒池。

類別

名稱 Description
AbstractExecutorService

提供執行方法的預設實作 ExecutorService 。

ArrayBlockingQueue

一個有界的阻塞隊列,由陣列作為後盾。

BrokenBarrierException

當執行緒嘗試等待處於破壞狀態的障礙,或在執行緒等待時進入破壞狀態時,會拋出異常。

CancellationException

例外表示一個產生價值的任務(如 FutureTask,)的結果無法被檢索,因為該任務已被取消。

CompletableFuture

Future A 可明確完成(設定其值與狀態),並可作為CompletionStage支援後續函式與動作的 ,並在完成時觸發。

CompletionException

當在完成結果或任務過程中遇到錯誤或其他異常時,會拋出異常。

ConcurrentHashMap

一個支援全檢索並行及高預期並行以更新的雜湊表。

ConcurrentLinkedDeque

基於連結節點的無界並行 Deque deque。

ConcurrentLinkedQueue

基於連結節點的無界安全執行緒佇列。

ConcurrentSkipListMap

一個可擴展的並行 ConcurrentNavigableMap 實作。

CopyOnWriteArrayList

一個執行緒安全的變體, java.util.ArrayList 所有變異操作(add、 set、 等)皆透過製作底層陣列的全新副本來實作。

CopyOnWriteArraySet

一個 Set 在所有操作中使用內部的 Inite CopyOnWriteArrayList 。

CountDownLatch

一種同步輔助工具,允許一個或多個執行緒等待其他執行緒執行的一組操作完成。

CountedCompleter

ForkJoinTask A 在觸發時執行完成動作,且沒有剩餘待處理的動作。

CyclicBarrier

一種同步輔助工具,允許一組執行緒彼此等待,直到達到共同的障礙點。

DelayQueue

無界的阻塞佇列(BlockingQueue)是元素 Delayed 阻塞佇列,其中元素通常在其延遲到期後才有資格被移除。

Exchanger

一個同步點,執行緒可以配對並在成對中交換元素。

ExecutionException

當嘗試以拋出例外來取回中止任務結果時,會拋出異常。

ExecutorCompletionService

CompletionService A 使用 sserved Executor 來執行任務。

Executors

本套件中定義了 Executor、 ExecutorService、 ScheduledExecutorServiceThreadFactoryCallable 、 及類別的工廠與工具方法。

Flow

相互關聯的介面與靜態方法,用於建立流量控制元件,其中 Publisher Publishers 產生由一個或多個 Subscriber Subscribers消耗的項目,每個項目由 Subscription Subscription管理。

ForkJoinPool

An ExecutorService 用於跑步 ForkJoinTask。

ForkJoinTask

抽象基底類別,用於在 ForkJoinPool.

ForkJoinWorkerThread

一個由 ForkJoinPool管理的執行緒,執行 ForkJoinTasks。

FutureTask

一種可取消的非同步計算。

IBlockingDequeExtensions

實作。

ThreadPoolExecutor類別並ScheduledThreadPoolExecutor提供可調校且彈性的執行緒池。

IBlockingQueueExtensions

實作。

ThreadPoolExecutor類別並ScheduledThreadPoolExecutor提供可調校且彈性的執行緒池。

IExecutorServiceExtensions

實作。

ThreadPoolExecutor類別並ScheduledThreadPoolExecutor提供可調校且彈性的執行緒池。

IFuture.State

代表計算狀態。

IFutureExtensions

實作。

ThreadPoolExecutor類別並ScheduledThreadPoolExecutor提供可調校且彈性的執行緒池。

LinkedBlockingDeque

一個可選有界的 BlockingDeque 阻擋 基於連結節點的阻擋 Deque。

LinkedBlockingQueue

一個可選的有界 BlockingQueue 封鎖佇列,基於連結節點。

LinkedTransferQueue

一個基於連結節點的無界。TransferQueue

Phaser

一個可重複使用的同步障礙,功能類似 CyclicBarrier 且 CountDownLatch 支援更靈活的使用。

PriorityBlockingQueue

一個無界的阻塞佇列,使用與類別 PriorityQueue 相同的排序規則,並提供阻塞檢索操作。

RecursiveAction

遞迴且無 ForkJoinTask結果。

RecursiveTask

一個遞迴結果 ForkJoinTask。

RejectedExecutionException

當任務無法被接受執行時,會拋 Executor 出異常。

ScheduledThreadPoolExecutor

ThreadPoolExecutor此外,還能排程指令在指定延遲後執行,或定期執行。

Semaphore

一個計數信號旗。

SubmissionPublisher

一個 Flow.Publisher 非同步地將提交的(非空)項目發送給現有訂閱者,直到訂閱結束。

SynchronousQueue

一個阻擋隊列,每個插入操作必須等待另一執行緒相應的移除操作,反之亦然。

ThreadLocalRandom

一個隨機數產生器(週期2<>為64</sup>),被隔離於當前執行緒。

ThreadPoolExecutor

一個 ExecutorService 會用可能的多個池執行緒執行每個提交任務,通常透過 Executors 工廠方法配置。

ThreadPoolExecutor.AbortPolicy

一個處理被拒絕任務的處理器,會拋出一個 RejectedExecutionException。

ThreadPoolExecutor.CallerRunsPolicy

一個處理被拒絕任務的處理程序,直接在方法的 execute 呼叫執行緒中執行被拒絕的任務,除非執行程序已被關閉,此時該任務會被丟棄。

ThreadPoolExecutor.DiscardOldestPolicy

一個處理被拒絕任務的處理器,會丟棄最早未處理的請求,然後重試 execute,除非執行器被關閉,此時該任務會被丟棄。

ThreadPoolExecutor.DiscardPolicy

一個默默處理被拒絕任務的處理者。

TimeoutException

當阻擋操作逾時時,會拋出例外。

TimeUnit

TimeUnit表示指定數據粒度單位的時間持續時間,並提供公用程式方法,以跨單位轉換,並在這些單位中執行計時和延遲作業。

介面

名稱 Description
CompletableFuture.IAsynchronousCompletionTask

一個標記介面,識別由 async 方法產生的非同步任務。

Flow.IProcessor

一個同時扮演訂閱者與 Publisher 角色的元件。

Flow.IPublisher

訂閱者接收的項目(及相關控制訊息)的產生者。

Flow.ISubscriber

一個接收訊息的人。

Flow.ISubscription

訊息控制連結 a Publisher 與 Subscriber。

ForkJoinPool.IForkJoinWorkerThreadFactory

用來創造新 ForkJoinWorkerThreads.

ForkJoinPool.IManagedBlocker

用於擴展在 s 中 ForkJoinPool執行任務的管理平行處理介面。

IBlockingDeque

Deque A還支援阻塞操作,即在取回元素時等待排隊列非空,並在儲存元素時等待排隊列中空位。

IBlockingQueue

Queue A 也支援在取用元素時等待佇列非空,並在儲存元素時等待佇列空間可用。

ICallable

一個會回傳結果並可能拋出例外的任務。

ICompletionService

一項服務,將新非同步任務的產生與完成任務結果的消費分離。

ICompletionStage

可能是非同步計算的一個階段,當另一個完結階段完成時執行動作或計算值。

IConcurrentMap

Map A 提供執行緒安全與原子性保證。

IDelayed

一種混合式介面,用於標記在特定延遲後應被處理的物件。

IExecutor

一個執行已提交 Runnable 任務的物件。

IExecutorService

A Executor 提供管理終止的方法,以及能產生 Future 追蹤一個或多個非同步任務進度的方法。

IFuture

A Future 代表非同步計算的結果。

IRejectedExecutionHandler

一個處理程序,用於無法被 ThreadPoolExecutor執行的任務。

IRunnableFuture

Future,即 Runnable。

IRunnableScheduledFuture

ScheduledFuture,即 Runnable。

IScheduledExecutorService

一個 ExecutorService 可以排程指令在特定延遲後執行,或定期執行的指令。

IScheduledFuture

一種延遲且可取消的結果作用。

IThreadFactory

一個能按需建立新執行緒的物件。

ITransferQueue

生產 BlockingQueue 者可以等待消費者接收元素。