Java多线程通信：wait(), notify()与CountDownLatch实战

原创太过爱你忘了你带给我的痛 2024-10-25 20:03 14阅读 0赞

在Java多线程中，`wait()`、`notify()`和`CountDownLatch`是用于线程间同步的关键工具。

1. `wait()`：
   当一个线程调用此方法时，它会释放对象监视器（通常是对象的锁），并将自身状态变为等待状态。只有当另一个线程调用`notify()`或`notifyAll()`方法后，等待的线程才会被唤醒并继续执行。

2. `notify()`/`notifyAll()`：
   当一个线程需要唤醒等待的线程时，通常会调用`notify()`或`notifyAll()`。前者仅唤醒一个等待的线程，后者则唤醒所有等待的线程。

3. `CountDownLatch`：
   `CountDownLatch`是一个同步工具，它有一个初始计数器值。当一个线程调用`await()`方法时，它的执行会被挂起，直到其他线程调用`countDown()`方法将计数器减1。减1的次数等于最初设置的计数器值，当计数达到0时，所有等待的线程都将被唤醒。

实战示例：
```java
// 创建CountDownLatch
 CountDownLatch countDownLatch = new CountDownLatch(3);

// 定义多个线程，每个线程执行不同的任务，并调用await方法
 Thread thread1 = new Thread(() -> {
    try {
        countDownLatch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("Thread 1 completed");
}));

Thread thread2 = new Thread(() -> {
    try {
        countDownLatch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("Thread 2 completed");
}));

Thread thread3 = new Thread(() -> {
    try {
        countDownLatch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("Thread 3 completed");
});

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

// 当所有任务完成后，调用countDown方法减少计数器值
countDownLatch.countDown();

```
这段代码中，创建了三个线程，每个线程都会等待`CountDownLatch`的计数减为0。当所有线程都完成任务后，通过调用`countDown()`方法来减少计数，唤醒等待的线程。