Java并发工具：CountDownLatch和CyclicBarrier使用示例

原创傷城~ 2024-10-15 22:12 69阅读 0赞

CountDownLatch和CyclicBarrier是Java中的两个重要并发工具，它们在控制多个线程的执行顺序上有各自的应用场景。以下是这两个工具的使用示例：

1. CountDownLatch（计数器倒计时）

当一个任务完成，并通知其他等待的任务时，可以使用CountDownLatch。其构造方法接受一个初始值。

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

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

public void task() throws InterruptedException {
        // 执行任务...
        latch.countDown();
        System.out.println("Task completed successfully.");
    }

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

new Thread(example::task).start();

try {
            example.latch.await();
            System.out.println("All tasks completed.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

2. CyclicBarrier（循环栅栏）

CyclicBarrier用于一组线程在达到预设条件后，等待并一起通过屏障。其构造方法接受一个预期的调用次数。

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

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

public void task1() throws InterruptedException {
        try {
            barrier.await();
            System.out.println("Task 1 completed.");
        } catch (Exception e) {
            System.out.println("Error in Task 1: " + e.getMessage());
        }
    }

public void task2() throws InterruptedException {
        try {
            barrier.await();
            System.out.println("Task 2 completed.");
        } catch (Exception e) {
            System.out.println("Error in Task 2: " + e.getMessage());
        }
    }

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

new Thread(example::task1).start();
        new Thread(example::task2)).start();

try {
            barrier.await(); // 等待所有任务完成
            System.out.println("All tasks completed.");
        } catch (Exception e) {
            System.out.println("Error in main method: " + e.getMessage());
        }
    }
}
```

以上示例展示了如何使用CountDownLatch和CyclicBarrier进行并发控制。