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 所有變異操作(addset、 等)皆透過製作底層陣列的全新副本來實作。

CopyOnWriteArraySet

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

CountDownLatch

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

CountedCompleter

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

CyclicBarrier

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

DelayQueue

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

Exchanger

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

ExecutionException

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

ExecutorCompletionService

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

Executors

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

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

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

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 PublisherSubscriber

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 者可以等待消費者接收元素。