Java中并发工具类：CountDownLatch和CyclicBarrier示例

原创爱被打了一巴掌 2024-11-24 16:42 6阅读 0赞

在Java中，CountDownLatch和CyclicBarrier是两种常用的并发工具类。它们主要用于协调多个线程的执行。

1. CountDownLatch示例：

```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private final CountDownLatch signal = new CountDownLatch(1);

public void task() throws InterruptedException {
        System.out.println("Starting task");
        signal.await(); // 等待信号
        System.out.println("Task completed");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();
        new Thread(example::task).start();
        System.out.println("Main thread finished");
    }
}
```

在这个例子中，一个任务线程会等待CountDownLatch的信号。当主线程发出信号（调用`signal.countDown()`）后，任务线程才能继续执行。

2. CyclicBarrier示例：

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

public class CyclicBarrierExample {
    private final CyclicBarrier barrier = new CyclicBarrier(2, "Finished"));

public void task1() throws Exception {
        System.out.println("Task 1 starting");
        barrier.await(); // 等待栅栏到达某个位置
        System.out.println("Task 1 completed");
    }

public void task2() throws Exception {
        System.out.println("Task 2 starting");
        barrier.await(); // 等待栅栏到达某个位置
        System.out.println("Task 2 completed");
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample();
        new Thread(example::task1).start();
        new Thread(example::task2)).start();
    }
}
```

在这个例子中，两个任务线程会等待CyclicBarrier的信号。当第一个线程到达`barrier.await();`时，它会被允许继续执行。然后第二个线程也会等待并完成任务。