并发编程系列：4大并发工具类的功能、原理、以及应用场景

一：并发工具包

1.并发工具类

提供了比synchronized更加高级的各类同步结构：包括CountDownLatch、CyclicBarrier、Semaphore等，能够实现更加丰富的多线程操做。

2.并发容器

提供各类线程安全的容器：最多见的ConcurrentHashMap、ConcurrentSkipListMap,实现线程安全的动态数组CopyOnWriteArrayList等。

3.并发队列

各类BlockingQueue的实现：经常使用的ArrayBlockingQueue、SynchorousQueue、特定场景的PriorityBlockingQueue。

4.Executor框架

能够建立各类不一样类型的线程池，调度任务运行等，绝大部分状况下，再也不须要本身从头实现线程池和任务调度器。

2、常见的并发容器

1.ConcurrentHashMap

常用的并发容器，JDK 1.7和1.8的底层数据结构发生了变化(后续文章会详解)，这里能够建议学习顺序以下：从Java7 HashMap -> Java7 ConcurrentHashMap -> Java8 HashMap -> Java8 ConcurrentHashMap，这样能够更好的掌握这个并发容器，毕竟都是从HashMap进化而来。

2.ConcurrentSkipListMap

在意顺序，须要对数据进行很是频繁的修改

3.CopyOnWrite容器

CopyOnWrite容器即写时复制的容器。从JDK1.5开始Java并发包里提供了两个使用CopyOnWrite机制实现的并发容器,CopyOnWriteArrayList和CopyOnWriteArraySet。

4.各类并发队列的实现

如各类BlockedQueue实现，比较典型的ArrayBlockingQueue、SynchorousQueue。

3、常见的并发工具

1.CountDownLatch

功能：

CountDownLatch是一个同步的辅助类，容许一个或多个线程，等待其余一组线程完成操做，再继续执行。

原理：

CountDownLatch是经过一个计数器来实现的，计数器的初始值为须要等待线程的数量。

eg：CountDownLatch c = new CountDownLatch(10); // 等待线程的数量为10

主线程调用CountDownLatch的await()方法会阻塞当前线程(即:主线程在闭锁上等待)，直到计数器的值为0。

当一个工做线程完成了本身的任务后，调用CountDownLatch的countDown()方法，计数器的值就会减1。

当计数器值为0时，说明全部的工做线程都执行完了，此时，在闭锁上等待的主线程就能够恢复执行任务。

应用场景：

倒数计时器

例如：一种典型的场景就是火箭发射。在火箭发射前，为了保证万无一失，每每还要进行各项设备、仪器的检查。 只有等全部检查完毕后，引擎才能点火。这种场景就很是适合使用CountDownLatch。

它可使得点火线程，等待全部检查线程所有完工后，再执行

使用方式：

static final CountDownLatch end = new CountDownLatch(10);end.countDown(); end.await(); 2.CyclicBarrier

功能:

CyclicBarrier的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要作的事情是，让一组线程到达一个屏障（也能够叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，全部被屏障拦截的线程才会继续运行。

和CountDownLatch类似，也是等待某些线程都作完之后再执行。

与CountDownLatch区别：

在于这个计数器能够反复使用。好比，假设咱们将计数器设置为10。那么凑齐第一批1 0个线程后，计数器就会归零，而后接着凑齐下一批10个线程。

原理：

1)CyclicBarrier是经过一个计数器来实现的，计数器的初始值为须要等待线程的数量。eg：CyclicBarrier c = new CyclicBarrier(2); // 等待线程的数量为2

2)每一个线程调用CyclicBarrier的await()方法，使本身进入等待状态。

3)当全部的线程都调用了CyclicBarrier的await()方法后，全部的线程中止等待，继续运行。

使用方式：

public CyclicBarrier(int parties, Runnable barrierAction) barrierAction就是当计数器一次计数完成后，系统会执行的动做await()

3.信号量Semaphore

功能：

Java提供了经典信号量Semaphore的实现，它经过控制必定数量的许可（permit）的方式，来达到限制通用资源访问的目的。例如：控制并发的线程数。

原理：

1)Semaphore是经过一个计数器(记录许可证的数量)来实现的，计数器的初始值为须要等待线程的数量。

eg：Semaphore s = new Semaphore(10); // 线程最大的并发数为10

2)线程经过acquire()方法获取许可证(计数器的值减1)，只有获取到许可证才能够继续执行下去，不然阻塞当前线程。

3)线程经过release()方法归还许可证(计数器的值加1)。

说明：使用tryAcquire()方法能够当即获得执行的结果：尝试获取一个许可证，若获取成功，则当即返回true，若获取失败，则当即返回false。

应用场景：

Semaphore能够用于作流量控制，特别是公用资源有限的应用场景，好比数据库链接。

举一个场景：例如在车站、机场等出租车时，当不少空出租车就位时，为防止过分拥挤，调度员指挥排队等待坐车的队伍一次进来5我的上车，等这5我的坐车出发，再放进去下一批。这和Semaphore的工做原理有些相似。

4.交换者Exchanger

功能：

Exchanger（交换者）是一个用于线程间协做的工具类。Exchanger用于进行线程间的数据交换。

原理：

它提供一个同步点，在这个同步点两个线程能够交换彼此的数据。

这两个线程经过exchange方法交换数据， 若是第一个线程先执行exchange方法，它会一直等待第二个线程也执行exchange，当两个线程都到达同步点时，这两个线程就能够交换数据，将本线程生产出来的数据传递给对方。

Exchanger的应用场景

Exchanger能够用于校对工做的场景。