Java并发工具：CountDownLatch和CyclicBarrier的应用示例

原创系统管理员 2024-11-06 18:04 15阅读 0赞

Java并发工具`CountDownLatch`和`CyclicBarrier`都是用于控制并发执行的工具，它们可以帮助协调多个线程的执行。

### CountDownLatch`CountDownLatch`是一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

**应用示例：**

假设我们有一个任务，需要等待所有子任务完成后才能继续执行。我们可以使用`CountDownLatch`来实现这一点。

```javaimport java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
 public static void main(String[] args) throws InterruptedException {
 final int threadCount =5;
CountDownLatch latch = new CountDownLatch(threadCount);

for (int i =0; i < threadCount; i++) {
 new Thread(new Worker(latch)).start();
 }

latch.await(); //等待所有子任务完成 System.out.println("所有子任务完成，主任务继续执行");
 }

static class Worker implements Runnable {
 private final CountDownLatch latch;

public Worker(CountDownLatch latch) {
 this.latch = latch;
 }

@Override public void run() {
 try {
//执行子任务 System.out.println(Thread.currentThread().getName() + "正在执行子任务");
Thread.sleep(1000); //模拟任务执行时间} catch (InterruptedException e) {
e.printStackTrace();
} finally {
 latch.countDown(); //子任务完成，计数减1 }
 }
 }
}
```### CyclicBarrier`CyclicBarrier`是一个同步辅助类，它允许一组线程互相等待，直到所有线程都到达一个公共屏障点（barrier point）。

**应用示例：**

假设我们有一个任务，需要所有线程都准备好后，才能一起执行下一步操作。我们可以使用`CyclicBarrier`来实现这一点。

```javaimport java.util.concurrent.CyclicBarrier;
import java.util.concurrent.BrokenBarrierException;

public class CyclicBarrierExample {
 public static void main(String[] args) {
 final int threadCount =5;
CyclicBarrier barrier = new CyclicBarrier(threadCount, new Runnable() {
@Override public void run() {
 System.out.println("所有线程都准备好了，一起执行下一步操作");
 }
 });

for (int i =0; i < threadCount; i++) {
 new Thread(new Worker(barrier)).start();
 }
 }

static class Worker implements Runnable {
 private final CyclicBarrier barrier;

public Worker(CyclicBarrier barrier) {
 this.barrier = barrier;
 }

@Override public void run() {
 try {
//执行准备工作 System.out.println(Thread.currentThread().getName() + "正在做准备工作");
Thread.sleep((long) (Math.random() *1000)); //模拟不同线程准备时间不同 barrier.await(); //等待所有线程都准备好//执行下一步操作 System.out.println(Thread.currentThread().getName() + "执行下一步操作");
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
 }
 }
 }
}
```这两个工具在并发编程中非常有用，可以帮助我们更好地控制线程的执行流程。