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

原创谁借莪１个温暖的怀抱￠ 2024-09-10 08:33 90阅读 0赞

`CountDownLatch`和`CyclicBarrier`是Java中两个常用的并发工具，主要用于协调多个线程的执行。

1. CountDownLatch使用案例：

- 多个任务完成后释放一个信号，其他任务等待这个信号。
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private CountDownLatch countDownLatch;

public CountDownLatchExample(int tasks) {
        countDownLatch = new CountDownLatch(tasks);
    }

// 任务线程
    public void taskThread() throws InterruptedException {
        countDownLatch.await(); // 等待信号

System.out.println("Task executed successfully");
    }

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

Thread thread1 = new Thread(example::taskThread);
        Thread thread2 = new Thread(example::taskThread));
        Thread thread3 = new Thread(example::taskThread));
        Thread thread4 = new Thread(example::taskThread));

thread1.start();
        thread2.start();
        thread3.start();
        thread4.start();
    }
}
```

2. CyclicBarrier使用案例：

- 当线程数量达到预设值时，所有线程一起等待某个操作完成。
```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private CyclicBarrier cyclicBarrier;

public CyclicBarrierExample(int participants) {
        cyclicBarrier = new CyclicBarrier(participants, "Task completed"));
    }

// 线程任务
    public void taskThread() throws InterruptedException {
        try {
            cyclicBarrier.await(); // 等待信号
        } catch (Exception e) {
            System.out.println("Error occurred while waiting for barrier: " + e.getMessage());
            return;
        }

System.out.println("Task executed successfully");
    }

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

thread1.start();
        thread2.start();
        thread3.start();
        thread4.start();
    }
}
```

以上就是`CountDownLatch`和`CyclicBarrier`在Java并发工具中的使用案例。