Java并发包java.util.concurrent简介

    JDK从1.5在多线程编程中提供了并发包java.util.concurrent，此包包括了几个小的、已标准化的可扩展框架，以及一些提供有用功能的类。主要代码由大牛Doug Lea完成，其实是在jdk1.4时代，由于java语言内置对多线程编程的支持比较基础和有限，所以他写了这个，因为实在太过于优秀，所以被加入到jdk之中。

 

concurrent包基本有3个package组成
java.util.concurrent：提供大部分关于并发的接口和类，如BlockingQueue,Callable,ConcurrentHashMap,ExecutorService, Semaphore等
java.util.concurrent.atomic：提供所有原子操作的类， 如AtomicInteger, AtomicLong等；
java.util.concurrent.locks:提供锁相关的类, 如Lock, ReentrantLock, ReadWriteLock, Condition等；

 

也可以理解成下面四类：

1. 线程池 Executor Framework 以及定时任务相关的类库，包括 Timer 等；

2. 并发集合，包括 List、Queue、Map 和 Set 等；

3. 新的同步器，例如读写锁 ReadWriteLock 等；

4. 新的原子包装类，例如 AtomicInteger 等。

concurrent包的优点
1. 首先，功能非常丰富，诸如线程池(ThreadPoolExecutor)，CountDownLatch等并发编程中需要的类已经有现成的实现，不需要自己去实现一套；毕竟jdk1.4对多线程编程的主要支持几乎就只有Thread, Runnable,synchronized等
2. concurrent包里面的一些操作是基于硬件级别的CAS(compare and swap),就是在cpu级别提供了原子操作，简单的说就可以提供无阻塞、无锁定的算法； 而现代cpu大部分都是支持这样的算法的；

 

Executor ： 具体Runnable任务的执行者。
ExecutorService ： 一个线程池管理者，其实现类有多种，我会介绍一部分。我们能把Runnable,Callable提交到池中让其调度。

ScheduledExecutorService ： 一个 ExecutorService，可安排在给定的延迟后运行或定期执行的命令。
Semaphore ： 一个计数信号量
ReentrantLock ： 一个可重入的互斥锁定 Lock，功能类似synchronized，但要强大的多。
Future ： 是与Runnable,Callable进行交互的接口，比如一个线程执行结束后取返回的结果等等，还提供了cancel终止线程。
BlockingQueue ： 阻塞队列。
CompletionService : ExecutorService的扩展，可以获得线程执行结果的
CountDownLatch ： 一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。
CyclicBarrier ： 一个同步辅助类，它允许一组线程互相等待，直到到达某个公共屏障点
Future ： Future 表示异步计算的结果。

 

下图为java.util.concurrent(J.U.C)的完整结构图