深入解析Java并发工具：CountDownLatch和CyclicBarrier示例

原创怼烎@ 2024-09-29 13:57 59阅读 0赞

在Java编程中，`CountDownLatch`和`CyclicBarrier`是两种常用的并发工具，分别用于控制多个线程的等待和释放。

1. `CountDownLatch`：

`CountDownLatch`表示一个计数器，初始值为`N`（你可以初始化为任何正整数），当某个线程调用`countDown()`方法时，会将计数器减一。当计数器的值变为零时，所有等待该信号的线程都将被唤醒。

示例：
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private CountDownLatch countDownLatch;

public CountDownLatchExample(int initialCount) {
        this.countDownLatch = new CountDownLatch(initialCount);
    }

public void signal() {
        countDownLatch.countDown();
    }

public void blockedThreadAction() throws InterruptedException {
        System.out.println("Blocked thread: waiting for signal...");
        countDownLatch.await();
        System.out.println("Blocked thread: signal received, proceeding.");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample(3);

// 创建两个线程
        Thread thread1 = new Thread(() -> example.blockedThreadAction()));
        Thread thread2 = new Thread(() -> example.signal()));

// 启动线程
        thread1.start();
        thread2.start();

// 等待所有线程执行完毕
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```
在这个示例中，我们创建了一个初始计数为3的`CountDownLatch`。然后创建了两个线程：一个在主线程中调用`blockedThreadAction()`等待信号到达；另一个调用`signal()`直接释放信号。

当信号被释放后，`await()`方法将在等待该信号的线程中阻塞，直到收到信号。最后，我们使用`join()`方法来确保所有线程执行完毕。