并发编程第八章：Java中的并发工具类

CountDownLatch
CyclicBarrier
Semaphore
Exchanger

CountDownLatch

CountDownLatch允许一个或多个线程等待其他线程完成操作。CountDownLatch 是通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减 1。当计数器值到达 0时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。
核心 API：

CountDownLatch(int count)：构造器，传入要等待的线程数。计数器 count 只能被设置一次。
countDown()：调用时 state（count）就会减1。
await()、await(long time，TimeUnit unit)：阻塞线程。

CyclicBarrier
CyclicBarrier的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续运行。
核心 API：
CyclicBarrier(int parties)：参数表示屏障拦截的线程数量。
CyclicBarrier(int parties，Runnable barrier-action)：用于在线程到达屏障时，优先执行barrierAction。
await()：线程调用该方法，告诉 CyclicBarrier 已经到达屏障，然后当前线程被阻塞。
reset()：重置计数器，并让线程重新运行一次。
getNumberWaiting()：获取 CyclicBarrier 阻塞的线程数量。
isBroken()：用来了解阻塞的线程是否被中断。

Semaphore
Semaphore（信号量）是用来控制同时访问特定资源的线程数量，它通过协调各个线程，以保证合理的使用公共资源。
API ：
Semaphore（int permits）：构造方法，permits 表示可用的许可证数量。
acquire()：获取一个许可证。
release()：归还一个许可证。
intavailablePermits()：返回此信号量中当前可用的许可证数。
intgetQueueLength()：返回正在等待获取许可证的线程数。
booleanhasQueuedThreads()：是否有线程正在等待获取许可证。
void reducePermits（int reduction）：减少reduction个许可证，是个 protected 方法。

Collection getQueuedThreads()：返回所有等待获取许可证的线程集合，是个 protected 方法。

Exchanger

Exchanger（交换者）是一个用于线程间协作的工具类。Exchanger用于进行线程间的数据交换。它提供一个同步点，在这个同步点，两个线程可以交换彼此的数据。这两个线程通过exchange方法交换数据，如果第一个线程先执行exchange()方法，它会一直等待第二个线程也执行exchange方法，当两个线程都到达同步点时，这两个线程就可以交换数据，将本线程生产出来的数据传递给对方。

public Class ExchangerTest{
  private static final Exchanger<String> exgr = new Exchanger<String>();
  private static ExecutorServicethreadPool = Executors.newFixedThreadPool(2);
  public static void main(String[] args) {
    threadPool.execute(new Runnable() {
      @Override
      public void run() {
        try {
            String A = "银行流水A";　　　　// A录入银行流水数据
            exgr.exchange(A);
        } catch (InterruptedException e) {
        }
      }
    });
  threadPool.execute(new Runnable() {
      @Override
      public void run() {
          try {
              String B = "银行流水B";　　　　// B录入银行流水数据
              String A = exgr.exchange("B");
              System.out.println("A和B数据是否一致：" + A.equals(B) + "，A录入的是：" + A + "，B录入是：" + B);
          } catch (InterruptedException e) {
          }
      }
  });
  threadPool.shutdown();
}
}

如果两个线程有一个没有执行exchange()方法，则会一直等待，如果担心有特殊情况发生，避免一直等待，可以使用exchange（V x，longtimeout，TimeUnit unit）设置最大等待时长。

CountDownLatch

CyclicBarrier

Semaphore

Exchanger