Java并发编程：CountDownLatch和Signal的交互实例

原创川长思鸟来 2024-11-08 10:18 6阅读 0赞

在Java并发编程中，`CountDownLatch` 是一个同步辅助类，用于在完成一组正在其他线程中执行的操作之前，允许一个或多个线程一直等待。`Signal`并不是Java标准库中的一个类或接口，但在这里我假设你指的是一种信号机制，可能是通过某种方式来通知线程继续执行。

以下是一个使用 `CountDownLatch` 的简单示例，其中主线程等待两个工作线程完成它们的任务：

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

public class CountDownLatchExample {
 public static void main(String[] args) throws InterruptedException {
// 创建一个CountDownLatch，计数器初始化为2，表示需要等待两个线程完成CountDownLatch latch = new CountDownLatch(2);

// 创建并启动两个线程Thread thread1 = new Thread(() -> {
 try {
 System.out.println("Thread1 is working...");
//模拟工作线程执行任务Thread.sleep(2000);
 System.out.println("Thread1 finished work.");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
//计数器减1 latch.countDown();
 }
 });

Thread thread2 = new Thread(() -> {
 try {
 System.out.println("Thread2 is working...");
//模拟工作线程执行任务Thread.sleep(3000);
 System.out.println("Thread2 finished work.");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
//计数器减1 latch.countDown();
 }
 });

thread1.start();
 thread2.start();

// 主线程等待两个工作线程完成 latch.await();
 System.out.println("Both threads have finished.");
 }
}
```在这个例子中，`CountDownLatch`被初始化为2，意味着主线程将等待两个工作线程完成它们的任务。每个工作线程在完成它们的任务后调用 `countDown()` 方法，这会将 `CountDownLatch` 的计数器减1。当计数器达到0时，`await()` 方法会返回，主线程继续执行。

如果你提到的“Signal”是指一种更具体的信号机制，比如使用 `Semaphore`、`CyclicBarrier` 或者 `Exchanger`等，那么可能需要一个不同的实现。如果你能提供更多的上下文或者具体的需求，我可以提供更具体的帮助。