Java并发工具：如CyclicBarrier和CountDownLatch的误用案例

原创亦凉 2024-09-11 01:03 65阅读 0赞

在Java并发编程中，CyclicBarrier和CountDownLatch是常用的同步工具。然而，如果使用不当，可能会导致一些错误。以下是一些误用案例：

1. **不满足条件就触发**：
   ```java
   CountDownLatch countDownLatch = new CountDownLatch(1);
   
   // 假设线程A负责触发条件
   Thread A = new Thread(() -> {
       // 模拟耗时操作，确保条件满足后才触发countDown
       Thread.sleep(2000); // 假定耗时2秒
       
       // 条件满足后调用countDownLatch的down方法
       countDownLatch.countDown();
   }));
   
   A.start(); // 启动线程A
   ```
   在上述例子中，如果模拟的耗时操作不足以满足条件，那么`countDownLatch.countDown();`将被提前执行，导致错误。

2. **无休止循环**：
   ```java
   CyclicBarrier barrier = new CyclicBarrier(3); // 设置为3个参与者

// 两个线程同时到达barrier
   Thread thread1 = new Thread(() -> {
       try {
           barrier.await(); // 等待barrier
           System.out.println("thread1 reached barrier");
         } catch (InterruptedException | BrokenBarrierException e) {
             System.out.println("Error reaching barrier: " + e);
         }
     }));
     
   Thread thread2 = new Thread(() -> {
       try {
           barrier.await(); // 等待barrier
           System.out.println("thread2 reached barrier");
         } catch (InterruptedException | BrokenBarrierException e) {
             System.out.println("Error reaching barrier: " + e);
         }
     }));
     
   thread1.start(); // 启动线程1
   thread2.start(); // 同时启动线程2

// 线程3始终无法到达barrier
   Thread thread3 = new Thread(() -> {
       try {
           barrier.await(); // 无论如何尝试，barrier都不会被触发
           System.out.println("thread3 attempted to reach barrier");
         } catch (InterruptedException | BrokenBarrierException e) {
             System.out.println("Error attempting to reach barrier: " + e);
         }
     }));
     
   thread3.start(); // 启动线程3

// 由于barrier没有被所有参与者触发，因此thread3将永远无法到达barrier
   ```
   在上述案例中，如果线程3始终无法触发CyclicBarrier的条件（即所有参与者都已到达），那么它将永远无法到达屏障。

总之，在使用Java并发工具时，一定要注意它们的设计目的和使用规则，避免因为误用导致的问题。