Java CyclicBarrier和CountDownLatch的区别
在Java中，CyclicBarrier和CountDownLatch是用于多线程协作的工具类，它们都可以用于线程间的同步和等待，但在使用方式和场景上有一些区别。
CyclicBarrier（循环屏障）：
- CyclicBarrier用于让多个线程相互等待，直到达到某个公共的屏障点，然后同时开始执行下一阶段的任务。
- CyclicBarrier可以重复使用，当所有线程都到达屏障点时，屏障会打开，所有线程可以继续执行后续任务。
- CyclicBarrier适用于任务分阶段执行的场景，要求多个线程在同一时间点相互等待，并且可以同时开始下一阶段的任务。
代码示例：
CyclicBarrier barrier = new CyclicBarrier(3, () -> {
// 当所有线程都到达屏障点时执行的任务
System.out.println("All threads reached the barrier");
});
// 线程1
new Thread(() -> {
// 线程1的任务
try {
Thread.sleep(1000);
System.out.println("Thread 1 finished");
barrier.await(); // 等待其他线程到达屏障点
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
}).start();
// 线程2和线程3类似
// 输出：
// Thread 1 finished
// Thread 2 finished
// Thread 3 finished
// All threads reached the barrier
CountDownLatch（倒计时门闩）：
- CountDownLatch用于实现一个或多个线程等待其他线程执行完毕的场景。
- CountDownLatch初始化一个计数器，每个线程执行完任务后将计数器减一，等待的线程调用await()方法等待计数器为零时继续执行。
- CountDownLatch一旦计数器为零，无法重置，所有等待的线程将同时被释放。
代码示例：
CountDownLatch latch = new CountDownLatch(3);
// 线程1
new Thread(() -> {
// 线程1的任务
System.out.println("Thread 1 finished");
latch.countDown(); // 计数器减一
}).start();
// 线程2和线程3类似
try {
latch.await(); // 等待计数器为零
System.out.println("All threads finished");
} catch (InterruptedException e) {
e.printStackTrace();
}
// 输出：
// Thread 1 finished
// Thread 2 finished
// Thread 3 finished
// All threads finished
CyclicBarrier和CountDownLatch的区别：
- CyclicBarrier适合线程间等待彼此达到屏障点，然后同时开始下一阶段的任务，可以重复使用。而CountDownLatch适合一个或多个线程等待其他线程执行完毕后再继续执行，计数器无法重置。
- CyclicBarrier更适合多阶段任务的协作，而CountDownLatch更适合某个任务的前置准备或者等待多个任务同时完成的场景。
根据具体的业务需求和协作场景，选择合适的同步工具类可以提高程序的可读性和可维护性。
