Java.Util.Concurrent 命名空间

实现。

ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。

AbstractExecutorService

提供执行方法的默认实现 ExecutorService

ArrayBlockingQueue

由数组支持的有限 BlockingQueue 阻止队列。

BrokenBarrierException

当线程尝试等待处于中断状态的屏障或线程正在等待时进入中断状态时引发的异常。

CancellationException

指示无法检索生成值的任务(如 a FutureTask)的结果的异常,因为任务已取消。

CompletableFuture

Future一个可以显式完成(设置其值和状态),并可用作CompletionStage支持在其完成时触发的依赖函数和操作。

CompletionException

在完成结果或任务的过程中遇到错误或其他异常时引发的异常。

ConcurrentHashMap

一个哈希表,支持完整并发检索和更新预期的高并发性。

ConcurrentLinkedDeque

基于链接节点的未绑定并发 Deque deque。

ConcurrentLinkedQueue

基于链接节点的未绑定线程安全队列队列。

ConcurrentSkipListMap

可缩放的并发 ConcurrentNavigableMap 实现。

CopyOnWriteArrayList

一种线程安全变体java.util.ArrayListset通过创建基础数组的新副本来实现所有可变操作(add等等)。

CopyOnWriteArraySet

Set用于其所有操作的内部CopyOnWriteArrayList函数。

CountDownLatch

一种同步帮助,允许一个或多个线程等待,直到在其他线程中执行一组操作完成。

CountedCompleter

ForkJoinTask触发时执行完成操作且没有剩余挂起的操作。

CyclicBarrier

一种同步帮助,允许一组线程全部等待对方到达一个常见屏障点。

DelayQueue

未绑定的 BlockingQueue 阻止元素队列,在该队列 Delayed 中,元素只能在其延迟到期时使用。

Exchanger

一个同步点,线程可以在配对中配对和交换元素。

ExecutionException

尝试通过引发异常来检索中止的任务的结果时引发的异常。

ExecutorCompletionService

使用提供的Executor用于执行任务的 ACompletionService

Executors

此包中定义的 、ExecutorService、、和ThreadFactory类的工厂和Callable实用工具方法ExecutorScheduledExecutorService

Flow

用于建立流控制组件的相互关联接口和静态方法,其中 Publisher Publishers 生成由一个或多个 Subscriber Subscribers由 a 管理 Subscription Subscription的项目。

ForkJoinPool

一个 ExecutorService 用于运行的 ForkJoinTasks。

ForkJoinTask

在一个 ForkJoinPool中运行的任务的抽象基类。

ForkJoinWorkerThread

ForkJoinPool执行 ForkJoinTask操作的线程。

FutureTask

可取消的异步计算。

IBlockingDequeExtensions

实现。

ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。

IBlockingQueueExtensions

实现。

ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。

IExecutorServiceExtensions

实现。

ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。

IFutureExtensions

实现。

ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。

LinkedBlockingDeque

基于链接节点的可选绑定 BlockingDeque 阻止 deque。

LinkedBlockingQueue

基于链接节点的(可选)绑定的 BlockingQueue 阻止队列。

LinkedTransferQueue

基于链接节点的 TransferQueue 未绑定。

Phaser

可重用的同步屏障,与功能 CyclicBarrier 类似, CountDownLatch 但支持更灵活的使用。

PriorityBlockingQueue

未绑定的 BlockingQueue 阻止队列,该队列使用与类 PriorityQueue 相同的排序规则并提供阻止检索操作。

RecursiveAction

递归的结果。ForkJoinTask

RecursiveTask

递归结果。ForkJoinTask

RejectedExecutionException

无法接受任务执行时引发 Executor 的异常。

ScheduledThreadPoolExecutor

可以 ThreadPoolExecutor 额外计划命令,以在给定的延迟后运行,或定期执行。

Semaphore

计数信号灯。

SubmissionPublisher

异步 Flow.Publisher 向当前订阅者提交(非 null)项,直到关闭。

SynchronousQueue

一个 BlockingQueue 阻止队列,其中每个插入操作必须等待另一个线程对应的删除操作,反之亦然。

ThreadLocalRandom

与当前线程隔离的随机数生成器(句号为 2<sup>64</sup>)。

ThreadPoolExecutor

使用 ExecutorService 可能有多个共用线程之一执行每个提交的任务,通常使用 Executors 工厂方法进行配置。

ThreadPoolExecutor.AbortPolicy

引发 . 的 RejectedExecutionException已拒绝任务的处理程序。

ThreadPoolExecutor.CallerRunsPolicy

一个处理程序,用于直接在方法的 execute 调用线程中运行已拒绝的任务,除非执行程序已关闭,在这种情况下,将放弃该任务。

ThreadPoolExecutor.DiscardOldestPolicy

拒绝的任务的处理程序,该处理程序放弃了最早的未经处理的请求,然后重试 execute,除非关闭执行程序,在这种情况下,将放弃该任务。

ThreadPoolExecutor.DiscardPolicy

拒绝任务的处理程序,该处理程序以无提示方式放弃已拒绝的任务。

TimeoutException

阻塞操作超时时引发的异常。

TimeUnit

A TimeUnit 表示给定粒度单位的时间持续时间,并提供用于跨单位转换的实用工具方法,并在这些单元中执行计时和延迟操作。

接口

CompletableFuture.IAsynchronousCompletionTask

标识方法生成的 async 异步任务的标记接口。

Flow.IProcessor

充当订阅服务器和发布服务器的组件。

Flow.IPublisher

订阅服务器收到的项(和相关控制消息)的生成者。

Flow.ISubscriber

消息接收器。

Flow.ISubscription

链接和 PublisherSubscriber. 的消息控件。

ForkJoinPool.IForkJoinWorkerThreadFactory

用于创建新 ForkJoinWorkerThreads 的工厂。

ForkJoinPool.IManagedBlocker

用于扩展在 s 中 ForkJoinPool运行的任务的托管并行度的接口。

IBlockingDeque

Deque它还支持阻止操作,这些操作在检索元素时等待 deque 变为非空,并在存储元素时等待 deque 中可用空间。

IBlockingQueue

此外 Queue ,它支持在检索元素时等待队列变为非空的操作,并在存储元素时等待队列中可用空间。

ICallable

返回结果并可能引发异常的任务。

ICompletionService

将新异步任务的生产与已完成任务结果的消耗分离的服务。

ICompletionStage

在完成另一个 CompletionStage 时,执行操作或计算值的可能异步计算的阶段。

IConcurrentMap

提供 Map 线程安全和原子性保证。

IDelayed

混合样式接口,用于标记应在给定延迟后执行操作的对象。

IExecutor

执行已 Runnable 提交任务的对象。

IExecutorService

Executor 提供用于管理终止的方法以及可以生成一 Future 个或多个异步任务的跟踪进度的方法。

IFuture

一个 Future 表示异步计算的结果。

IRejectedExecutionHandler

无法由 a . 执行的任务的 ThreadPoolExecutor处理程序。

IRunnableFuture

属于 RunnableFuture

IRunnableScheduledFuture

属于 RunnableScheduledFuture

IScheduledExecutorService

可以 ExecutorService 计划命令在给定延迟后运行,或定期执行。

IScheduledFuture

可以取消的延迟结果操作。

IThreadFactory

按需创建新线程的对象。

ITransferQueue

一个 BlockingQueue 生成者可以等待使用者接收元素。