Java常用的并发类工具（java 并发工具类）

一、常用的并发工具类有哪些？

1、CountDownLatch

作用：是一组线程等待其他的线程完成工作以后在执行，加强版join

await用来等待，countDown负责计数器的减一

2、CyclicBarrier

让一组线程达到某个屏障，被阻塞，一直到组内最后一个线程达到屏障时，屏障开放，所有被阻塞的线程会继续运行CyclicBarrier(int parties)

CyclicBarrier(int parties, Runnable barrierAction)，屏障开放，barrierAction定义的任务会执行

CountDownLatch和CyclicBarrier辨析

（1）、countdownlatch放行由第三者控制，CyclicBarrier放行由一组线程本身控制
（2）、countdownlatch放行条件》=线程数，CyclicBarrier放行条件=线程数

3、Semaphore

控制同时访问某个特定资源的线程数量，用在流量控制

4、Exchange

两个线程间的数据交换

二、CyclicBarrier和CountDownLatch的应用场景？

CountDownLatch：一个线程A等待其它线程都执行完毕后，这个线程A才继续执行。这个线程A也可以是一组线程(使用同一个CountDownLatch来控制即可).
CyclicBarrier：一组线程互相等待，当它们都达到各自await()指定的barrier时，它们再同时继续执行各自下面的代码。

大致实现如下：

CountDownLatch：使用await()让主线程A等待，然后其它线程执行完成时可以使用countDown()使计数减1，最终计数器被清0时，主线程继续执行，计数器是由CountDownLatch初始化时定义的:

final CountDownLatch latch = new CountDownLatch(2);
CyclicBarrier：一组线程使用await()指定barrier，所有线程都到达各自的barrier后，再同时执行各自barrier下面的代码。

三、CyclicBarrier和CountDownLatch的区别？

· CountDownLatch的计数器只能使用一次。而CyclicBarrier的计数器可以使用reset()方法重置。所以CyclicBarrier能处理更为复杂的业务场景，比如如果计算发生错误，可以重置计数器，并让线程们重新执行一次。

· CyclicBarrier还提供其他有用的方法，比如getNumberWaiting方法可以获得CyclicBarrier阻塞的线程数量。isBroken方法用来知道阻塞的线程是否被中断。比如以下代码执行完之后会返回true。

· CountDownLatch会阻塞主线程，CyclicBarrier不会阻塞主线程，只会阻塞子线程。

· 某线程中断CyclicBarrier会抛出异常，避免了所有线程无限等待。

我们来从jdk作者设计的目的来看，javadoc是这么描述它们的：

CountDownLatch:

A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

CyclicBarrier:

A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point.

从javadoc的描述可以得出：

· CountDownLatch：一个或者多个线程，等待其他多个线程完成某件事情之后才能执行；

· CyclicBarrier：多个线程互相等待，直到到达同一个同步点，再继续一起执行。

对于CountDownLatch来说，重点是“一个线程（多个线程）等待”，而其他的N个线程在完成“某件事情”之后，可以终止，也可以等待。而对于CyclicBarrier，重点是多个线程，在任意一个线程没有完成，所有的线程都必须等待。

CountDownLatch是计数器，线程完成一个记录一个，只不过计数不是递增而是递减，而CyclicBarrier更像是一个阀门，需要所有线程都到达，阀门才能打开，然后继续执行。

四、Semaphore的应用场景？

Semaphore可以用来做流量限制，特别是公共资源有限的应用场景，比如说数据库连接。

由于 release() 释放许可时，未对释放许可数做限制，所有可以通过该方法增加总的许可数量; reducePermits() 方法可以减少总的许可数量，通过这两个方法可以到达动态调整许可的