Package java.util.concurrent

在并发编程中常用的实用类。

See: 描述

接口摘要

接口	描述
BlockingDeque<E>	一，另外支持阻塞操作等待队列非空的检索成为一个元素时 Deque，等待空间变得可用时在deque容器存储元件。
BlockingQueue<E>	一，另外支持操作等待队列成为非空检索元素时， Queue，等待空间变得可用在排队的时候存储元件。
Callable<V>	返回结果的一个任务，并可能抛出异常。
CompletableFuture.AsynchronousCompletionTask	一个标记接口识别异步任务的 async方法产生。
CompletionService<V>	一种服务，将新的异步任务的生产从完成任务的结果消费。
CompletionStage<T>	一个可能的异步计算阶段，执行一个动作或计算值的另一completionstage完成时。
ConcurrentMap<K,V>	一个 Map提供线程安全性和原子性的保证。
ConcurrentNavigableMap<K,V>	一个 ConcurrentMap支持 NavigableMap操作，并递归地对其通航的子图。
Delayed	在一个给定的延迟后，应采取行动的标记对象的混合样式接口。
Executor	一个对象执行提交 Runnable任务。
ExecutorService	一个 Executor，管理终端和方法可以用于跟踪一个或多个异步任务的进展产生 Future提供方法。
ForkJoinPool.ForkJoinWorkerThreadFactory	创建新的 ForkJoinWorkerThreads厂。
ForkJoinPool.ManagedBlocker	扩展管理并行的任务运行在 ForkJoinPools接口。
Future<V>	一个 Future表示异步计算的结果。
RejectedExecutionHandler	对于无法通过 ThreadPoolExecutor执行任务的处理程序。
RunnableFuture<V>	这是一个 Future Runnable。
RunnableScheduledFuture<V>	这是一个 ScheduledFuture Runnable。
ScheduledExecutorService	一个 ExecutorService可以调度命令后运行一个给定的延迟，或定期执行。
ScheduledFuture<V>	一种可以取消的延迟结果承载动作。
ThreadFactory	一个创建新线程的对象。
TransferQueue<E>	一个 BlockingQueue，生产者可以等待消费者接收元件。

类摘要

类	描述
AbstractExecutorService	提供 ExecutorService执行方法的默认实现。
ArrayBlockingQueue<E>	一个有界 blocking queue有一个数组。
CompletableFuture<T>	一个 Future可以明确完成（设定其价值和地位），可作为 CompletionStage，支持相关的功能和作用，触发后。
ConcurrentHashMap<K,V>	支持全并发检索和高预期的并发更新哈希表。
ConcurrentHashMap.KeySetView<K,V>	一个视图作为一个 Set ConcurrentHashMap的钥匙，在其中添加可使被映射到一个共同的价值。
ConcurrentLinkedDeque<E>	一个基于链接节点的并发 deque无界。
ConcurrentLinkedQueue<E>	一个基于链接节点的无界线程安全的 queue。
ConcurrentSkipListMap<K,V>	一个可扩展的并行 ConcurrentNavigableMap实施。
ConcurrentSkipListSet<E>	一个可扩展的并行 NavigableSet实现基于 ConcurrentSkipListMap。
CopyOnWriteArrayList<E>	一个线程安全的变量在所有的修改操作 ArrayList（ add， set，等等）都是通过底层数组的一个新版本的实现。
CopyOnWriteArraySet<E>	一个 Set，使用内部的 CopyOnWriteArrayList其所有操作。
CountDownLatch	一种同步帮助，允许一个或多个线程等待，直到在其他线程中执行的一组操作完成。
CountedCompleter<T>	一个执行时触发，没有剩余的未决诉讼 ForkJoinTask完成动作。
CyclicBarrier	一个同步帮助，允许一组线程相互等待，以达到一个共同的障碍点。
DelayQueue<E extends Delayed>	对 Delayed元素无界 blocking queue，其中一个元素只可以当其延迟已过期。
Exchanger<V>	线程可以对的同步点和对中的元素交换元素的同步点。
ExecutorCompletionService<V>	一个 CompletionService使用提供 Executor执行任务。
Executors	对于 Executor， ExecutorService， ScheduledExecutorService， ThreadFactory厂和实用方法，并 Callable类定义在这个包。
ForkJoinPool	运行一个 ExecutorService ForkJoinTasks。
ForkJoinTask<V>	对于运行在一个 ForkJoinPool任务抽象基类。
ForkJoinWorkerThread	一个线程的执行， ForkJoinPool管理， ForkJoinTasks。
FutureTask<V>	一个可以取消的异步计算。
LinkedBlockingDeque<E>	一个可选择的有界 blocking deque基于链接节点。
LinkedBlockingQueue<E>	一个可选择的有界 blocking queue基于链接节点。
LinkedTransferQueue<E>	基于链接节点的无界 TransferQueue。
Phaser	一个可重复使用的同步屏障，在功能 CyclicBarrier和 CountDownLatch相似但支持更灵活的使用。
PriorityBlockingQueue<E>	无界 blocking queue使用相同的排序规则类的 PriorityQueue供应阻断检索操作。
RecursiveAction	结果 ForkJoinTask递归。
RecursiveTask<V>	一个递归的结果 ForkJoinTask轴承。
ScheduledThreadPoolExecutor	一个 ThreadPoolExecutor可以另外安排的命令来运行在一个给定的延迟，或定期执行。
Semaphore	计数信号量。
SynchronousQueue<E>	一个 blocking queue其中每个插入操作必须等待相应的删除操作由另一个线程，反之亦然。
ThreadLocalRandom	一个与当前线程隔离的随机数发生器。
ThreadPoolExecutor	一个 ExecutorService执行每个提交的任务使用一个可能几个池线程，使用 Executors工厂方法通常配置。
ThreadPoolExecutor.AbortPolicy	对于拒绝任务，抛出一个 RejectedExecutionException处理程序。
ThreadPoolExecutor.CallerRunsPolicy	对于拒绝任务运行任务直接拒绝的 execute方法调用的线程处理，除非遗嘱执行人已被关闭，在这种情况下，任务被丢弃。
ThreadPoolExecutor.DiscardOldestPolicy	对于拒绝任务，抛弃了古老的未经处理的请求，然后重试 execute处理程序，除非遗嘱执行人是关闭的，在这种情况下，任务被丢弃。
ThreadPoolExecutor.DiscardPolicy	对于拒绝任务，默默丢弃拒绝任务处理程序。

枚举摘要

Enum	描述
TimeUnit	一个 TimeUnit代表时间在给定单位的粒度，提供实用的方法来转换过的单位，并进行定时和延时操作这些单位。

异常摘要

异常	描述
BrokenBarrierException	当一个线程试图等待处于一个处于中断状态的障碍，或在线程等待时进入中断状态的一个障碍物时引发的异常。
CancellationException	异常说明价值生产任务的结果，如 FutureTask，无法取回，因为任务被取消。
CompletionException	在完成结果或任务的过程中遇到错误或其他异常时引发的异常。
ExecutionException	当试图检索通过抛出异常中止的任务的结果时引发的异常。
RejectedExecutionException	抛出异常的 Executor当任务不能被执行。
TimeoutException	当阻塞操作超时时引发的异常。

Package java.util.concurrent Description

在并发编程中常用的实用类。这个软件包包括一些小的标准化可扩展的框架，以及一些类，提供有用的功能，否则繁琐或难以实现。这里是简要介绍的主要组成部分。又见 java.util.concurrent.locks和 java.util.concurrent.atomic包。

遗嘱执行人

接口。 Executor是定义自定义线程子系统一个简单的标准化接口，包括线程池，异步I/O，和轻量级任务框架。这取决于具体的执行者级正在使用，任务可以在一个新创建的线程执行，现有的任务执行线程的线程调用，或 execute，可以依次或同时执行。 ExecutorService提供了更完整的异步任务执行框架。一个服务管理排队和调度任务，并允许控制关机。的 ScheduledExecutorService接口和相关的接口添加延迟和周期性任务执行支持。executorservices提供方法安排表现为 Callable异步执行的任何功能， Runnable轴承模拟结果。一个 Future返回一个函数的结果，可以确定是否执行完成，并提供了一种手段来取消执行。一个 RunnableFuture是 Future具有在执行 run方法，设置它的结果。

实现。类ThreadPoolExecutor和ScheduledThreadPoolExecutor提供可调的、灵活的线程池。的Executors类提供了最常见的种类和配置执行工厂方法，以及一些实用的使用方法。基于Executors其他设施包括具体的类提供一个共同FutureTask期货，可扩展的实现和ExecutorCompletionService，帮助协调异步任务组的处理。

类ForkJoinPool提供执行器主要用于ForkJoinTask及其子类处理实例。这些类采用了工作窃取调度，达到高吞吐量的任务，符合限制，往往保持在计算密集型并行处理。

队列

的 ConcurrentLinkedQueue类提供了一个高效可扩展的线程安全的非阻塞FIFO队列。的 ConcurrentLinkedDeque类相似，但同时支持 Deque接口。

在java.util.concurrent五实现支持扩展BlockingQueue接口，定义阻塞版本会：LinkedBlockingQueue，ArrayBlockingQueue，SynchronousQueue，PriorityBlockingQueue，和DelayQueue。不同的类包括生产者消费者、消息传递、并行处理和相关并行设计的最常见的使用上下文上下文。

TransferQueue扩展接口，实现LinkedTransferQueue介绍同步transfer方法（以及相关的功能），生产者可以选择块等待消费者。

BlockingDeque接口扩展的BlockingQueue支持FIFO和LIFO（基于堆栈的）操作。类提供了一个实现LinkedBlockingDeque。

定时

的 TimeUnit类提供了多粒度（包括纳秒）指定和控制的基于超时的操作。包中的大多数类都包含基于超时的操作，除了不确定的等待。在所有的情况下，超时使用，超时指定方法应该在表明它超时等待时间最小。实现“尽最大努力”，以检测超时，尽快后，他们发生。然而，一段时间从一个超时检测线实际执行后再次暂停。接受超时参数的所有方法处理值小于或等于零，意味着不等待。等待“永远”，你可以用一个价值 Long.MAX_VALUE。

同步化器

五类援助常见的专用同步成语。

• Semaphore是一个经典的并发工具。
• CountDownLatch是阻塞直到给定数量的信号，事件很简单但很常见的效用，或条件。
• 一个CyclicBarrier一些并行编程风格是可复位的多路同步点有用的。
• 一个Phaser提供了更灵活的屏障，可以用来控制相位计算的多个线程之间的形式。
• 一个Exchanger允许两个线程在一个交会点交换的对象，是有用的几个管道设计。

并发集合

除了队列，这包装用品收集实现设计中使用多线程的上下文： ConcurrentHashMap， ConcurrentSkipListMap， ConcurrentSkipListSet， CopyOnWriteArrayList，和 CopyOnWriteArraySet。当许多线程将访问给定的集合，一个 ConcurrentHashMap通常最好同步 HashMap，和 ConcurrentSkipListMap通常最好同步 TreeMap。一个 CopyOnWriteArrayList最好是同步的 ArrayList当预期数量的读取和遍历大大超过更新号码列表。

这个包中的一些类的“并发”前缀是一个表示类似“同步”类的几个区别的速记。例如java.util.Hashtable和Collections.synchronizedMap(new HashMap())同步。但ConcurrentHashMap是“并发”。并发集合是线程安全的，但不受一个单一的互斥锁的支配。在ConcurrentHashMap的具体情况，它安全地允许任何数量的并发读取以及写入一个可调谐的并发数量。”同步“类可以是有用的，当你需要通过一个单一的锁，以防止所有访问到一个集合，在牺牲较差的可扩展性。在其他情况下，多个线程将访问一个常见的集合，“并发”版本通常是最好的。和不同步的集合是最好的当集合是共享的，或是只有当持有其他锁。

大多数并行采集的实现（包括大多数队列）也不同于一般的java.util公约在其Iterators和Spliterators提供弱一致性而不是快速失败的遍历：

• 他们可以同时进行其他操作
• 他们永远不会把ConcurrentModificationException
• 他们保证遍历元素，因为它们存在于建设完全一次，并可能（但不保证）反映任何修改后的建设。

内存一致性

Chapter 17 of the Java Language Specification定义之前发生的关系对内存的操作如读取和写入共享变量。一个写一个线程，结果保证是可见的由另一个线程读写操作之前发生的只有读操作。的 synchronized和 volatile构造，以及 Thread.start()和 Thread.join()方法，可以形成之前发生的关系。特别是：

• 每一个动作在一个线程中的每一个动作，之前发生的线程是程序的命令后。
• 解锁（synchronized块或退出方法）一个监控之前发生的以后每锁（synchronized块或方法入口），监测。因为之前发生的关系是传递的，所有的行动，一个线程解锁发生过所有行动，随后的任何线程锁，监视器之前。
• 写一volatile场之前发生的那场以后每读。写入和读取volatile领域也有类似的内存一致性效应，进入和退出监视器，但不需要互斥锁。
• 一个叫start线程上启动的线程之前发生的任何行动。
• 线程中的所有行动发生过成功返回的任何其他线程从这个线程join。

java.util.concurrent及其子包中的所有类中的方法将这些保证更高级别的同步。特别是：

• 在将一个对象到任何并行采集发生过动作元素的访问和去除集合在另一个线程的线程随后行动之前。
• 在一个线程的一个Executor Runnable之前提交发生过执行行动开始。同样的Callables提交一ExecutorService。
• 通过Future发生过行动结果的检索随后通过在另一个线程Future.get()代表异步计算所采取的行动。
• 在“释放”同步方法如Lock.unlock，Semaphore.release行动，和CountDownLatch.countDown发生过行动后，一个成功的“收购”的方法，如Lock.lock，Semaphore.acquire，Condition.await，和在另一个线程同步对象CountDownLatch.await相同。
• 对每个线程成功交换对象通过一个Exchanger，行动之前的exchange()每个线程发生过那些在另一个线程对应的exchange()后续。
• 呼叫CyclicBarrier.await和Phaser.awaitAdvance之前的行动（以及它的变体）发生过行动的屏障作用，并通过屏障作用发生过行动从其他线程中相应的await成功返回后执行的动作。

从以下版本开始：

1.5