Java.Util.Concurrent 命名空间
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
实现。
类 ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。
类
AbstractExecutorService |
提供执行方法的默认实现 |
ArrayBlockingQueue |
由数组支持的有限 BlockingQueue 阻止队列。 |
BrokenBarrierException |
当线程尝试等待处于中断状态的屏障或线程正在等待时进入中断状态时引发的异常。 |
CancellationException |
指示无法检索生成值的任务(如 a |
CompletableFuture |
|
CompletionException |
在完成结果或任务的过程中遇到错误或其他异常时引发的异常。 |
ConcurrentHashMap |
一个哈希表,支持完整并发检索和更新预期的高并发性。 |
ConcurrentLinkedDeque |
基于链接节点的未绑定并发 Deque deque。 |
ConcurrentLinkedQueue |
基于链接节点的未绑定线程安全队列队列。 |
ConcurrentSkipListMap |
可缩放的并发 |
CopyOnWriteArrayList |
一种线程安全变体 |
CopyOnWriteArraySet |
|
CountDownLatch |
一种同步帮助,允许一个或多个线程等待,直到在其他线程中执行一组操作完成。 |
CountedCompleter |
|
CyclicBarrier |
一种同步帮助,允许一组线程全部等待对方到达一个常见屏障点。 |
DelayQueue |
未绑定的 BlockingQueue 阻止元素队列,在该队列 |
Exchanger |
一个同步点,线程可以在配对中配对和交换元素。 |
ExecutionException |
尝试通过引发异常来检索中止的任务的结果时引发的异常。 |
ExecutorCompletionService |
使用提供的 |
Executors |
此包中定义的 、 |
Flow |
用于建立流控制组件的相互关联接口和静态方法,其中 |
ForkJoinPool |
一个 |
ForkJoinTask |
在一个 |
ForkJoinWorkerThread |
由 |
FutureTask |
可取消的异步计算。 |
IBlockingDequeExtensions |
实现。 类 ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。 |
IBlockingQueueExtensions |
实现。 类 ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。 |
IExecutorServiceExtensions |
实现。 类 ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。 |
IFutureExtensions |
实现。 类 ThreadPoolExecutor 并提供 ScheduledThreadPoolExecutor 可调整的灵活线程池。 |
LinkedBlockingDeque |
基于链接节点的可选绑定 BlockingDeque 阻止 deque。 |
LinkedBlockingQueue |
基于链接节点的(可选)绑定的 BlockingQueue 阻止队列。 |
LinkedTransferQueue |
基于链接节点的 |
Phaser |
可重用的同步屏障,与功能 |
PriorityBlockingQueue |
未绑定的 BlockingQueue 阻止队列,该队列使用与类 |
RecursiveAction |
递归的结果。 |
RecursiveTask |
递归结果。 |
RejectedExecutionException |
无法接受任务执行时引发 |
ScheduledThreadPoolExecutor |
可以 |
Semaphore |
计数信号灯。 |
SubmissionPublisher |
异步 |
SynchronousQueue |
一个 BlockingQueue 阻止队列,其中每个插入操作必须等待另一个线程对应的删除操作,反之亦然。 |
ThreadLocalRandom |
与当前线程隔离的随机数生成器(句号为 2<sup>64</sup>)。 |
ThreadPoolExecutor |
使用 |
ThreadPoolExecutor.AbortPolicy |
引发 . 的 |
ThreadPoolExecutor.CallerRunsPolicy |
一个处理程序,用于直接在方法的 |
ThreadPoolExecutor.DiscardOldestPolicy |
拒绝的任务的处理程序,该处理程序放弃了最早的未经处理的请求,然后重试 |
ThreadPoolExecutor.DiscardPolicy |
拒绝任务的处理程序,该处理程序以无提示方式放弃已拒绝的任务。 |
TimeoutException |
阻塞操作超时时引发的异常。 |
TimeUnit |
A |
接口
CompletableFuture.IAsynchronousCompletionTask |
标识方法生成的 |
Flow.IProcessor |
充当订阅服务器和发布服务器的组件。 |
Flow.IPublisher |
订阅服务器收到的项(和相关控制消息)的生成者。 |
Flow.ISubscriber |
消息接收器。 |
Flow.ISubscription |
链接和 |
ForkJoinPool.IForkJoinWorkerThreadFactory |
用于创建新 |
ForkJoinPool.IManagedBlocker |
用于扩展在 s 中 |
IBlockingDeque |
|
IBlockingQueue |
此外 |
ICallable |
返回结果并可能引发异常的任务。 |
ICompletionService |
将新异步任务的生产与已完成任务结果的消耗分离的服务。 |
ICompletionStage |
在完成另一个 CompletionStage 时,执行操作或计算值的可能异步计算的阶段。 |
IConcurrentMap |
提供 |
IDelayed |
混合样式接口,用于标记应在给定延迟后执行操作的对象。 |
IExecutor |
执行已 |
IExecutorService |
它 |
IFuture |
一个 |
IRejectedExecutionHandler |
无法由 a . 执行的任务的 |
IRunnableFuture |
属于 |
IRunnableScheduledFuture |
属于 |
IScheduledExecutorService |
可以 |
IScheduledFuture |
可以取消的延迟结果操作。 |
IThreadFactory |
按需创建新线程的对象。 |
ITransferQueue |
一个 |