多线程同步任务：使用CountDownLatch和CyclicBarrier示例

原创我会带着你远行 2024-10-17 15:51 26阅读 0赞

CountDownLatch和CyclicBarrier是Java中两种常用的多线程同步工具。下面我将分别给出这两种工具的使用示例。

1. CountDownLatch

CountDownLatch用于一个或多个线程等待其他线程完成特定工作后执行。它有一个初始值，当一个线程调用`countDown()`方法时，该值会减一。

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

public class CountDownLatchExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建CountDownLatch，初始值为3
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建两个线程，每个线程执行一个任务并调用countDown()
        Thread task1Thread = new Thread(() -> {
            try {
                countDownLatch.countDown();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread task2Thread = new Thread(() -> {
            try {
                countDownLatch.countDown();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        task1Thread.start();
        task2Thread.start();

// 等待所有任务完成
        countDownLatch.await();

System.out.println("All tasks completed!");
    }
}
```

2. CyclicBarrier

CyclicBarrier用于一组等待其他线程完成特定工作后执行的线程。当一个线程调用`await()`方法时，该线程会挂起直到有另一个线程调用`countDown()`方法。

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

public class CyclicBarrierExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建CyclicBarrier，初始值为2
        CyclicBarrier cyclicBarrier = new CyclicBarrier(2);

// 创建两个线程，每个线程执行一个任务并调用countDown()
        Thread task1Thread = new Thread(() -> {
            try {
                cyclicBarrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread task2Thread = new Thread(() -> {
            try {
                cyclicBarrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        task1Thread.start();
        task2Thread.start();

// 等待所有任务完成
        System.out.println("All tasks completed!");
    }
}
```

这两种工具在多线程同步场景中有着广泛的应用。