多线程同步问题示例：Java中CountDownLatch使用不当

原创ゝ一纸荒年。 2024-10-31 15:39 26阅读 0赞

在Java中，`CountDownLatch` 是一个同步辅助类，用于在完成一组正在其他线程中执行的操作之前，允许一个或多个线程一直等待。如果使用不当，可能会导致程序出现死锁、资源浪费或者程序逻辑错误等问题。下面是一个使用不当的 `CountDownLatch` 示例，以及如何正确使用它。

### 使用不当的示例```javaimport java.util.concurrent.CountDownLatch;

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

new Thread(() -> {
 try {
//模拟耗时操作Thread.sleep(2000);
 System.out.println("任务完成");
} finally {
 latch.countDown(); //减少计数 }
 }).start();

//错误的使用：在主线程中等待，但主线程可能先于子线程执行完毕 latch.await();
 System.out.println("主线程继续执行");
 }
}
```在这个例子中，`CountDownLatch`被初始化为1，意味着主线程将等待子线程中的 `countDown()`被调用。然而，如果子线程执行的耗时操作比主线程的 `await()`调用更快完成，那么 `await()`将立即返回，导致主线程不会等待子线程完成，这并不是我们想要的结果。

###正确的使用方式为了确保主线程能够正确等待子线程完成，我们可以将 `await()`调用放在一个循环中，或者使用 `try-catch`块来处理 `InterruptedException`：

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

public class CorrectCountDownLatchExample {
 public static void main(String[] args) {
CountDownLatch latch = new CountDownLatch(1);

new Thread(() -> {
 try {
//模拟耗时操作Thread.sleep(2000);
 System.out.println("任务完成");
} finally {
 latch.countDown(); //减少计数 }
 }).start();

try {
 latch.await(); //正确使用：等待直到计数器为0 System.out.println("主线程继续执行");
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); //重新设置中断状态e.printStackTrace();
 }
 }
}
```在这个修正后的示例中，我们使用 `try-catch`块来捕获可能的 `InterruptedException`，并且在捕获异常后重新设置中断状态。这样可以确保即使在子线程执行期间主线程被中断，程序也能正确处理中断情况，并且主线程会等待子线程完成。

正确使用 `CountDownLatch`可以避免程序逻辑错误和资源浪费，确保程序的同步性和稳定性。