Java并发编程中CountDownLatch和Semaphore的应用示例

原创一时失言乱红尘 2024-12-07 19:30 8阅读 0赞

CountDownLatch和Semaphore都是Java中用于管理线程执行顺序的同步工具。以下分别提供这两种工具的应用示例：

1. CountDownLatch：

CountDownLatch用于一个或多个任务完成后通知其他等待的任务。

```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private CountDownLatch countDownLatch = new CountDownLatch(2);

public void taskA() throws InterruptedException {
        System.out.println("Task A starting...");
        countDownLatch.await();
        System.out.println("Task A completed.");
    }

public void taskB() throws InterruptedException {
        System.out.println("Task B starting...");
        countDownLatch.countDown(); // 当计数器减少到0时，通知countDownLatch
        countDownLatch.await();
        System.out.println("Task B completed.");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();
        new Thread(example::taskA).start();
        new Thread(example::taskB).start();
    }
}
```

2. Semaphore：

Semaphore用于控制对共享资源的访问。它的值范围是0到max value，当值为0表示无许可（no permit），而大于0则表示有最大数量的许可。

```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1); // 创建一个允许一次获取的Semaphore

public void taskA() throws InterruptedException {
        System.out.println("Task A starting...");
        semaphore.acquire(); // 获取许可证，如果已达到最大值则阻塞
        System.out.println("Task A completed.");
    }

public void taskB() throws InterruptedException {
        System.out.println("Task B starting...");
        semaphore.release(); // 释放许可证，如果当前值为0，则会抛出异常（UnderflowException）
        System.out.println("Task B completed.");
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        new Thread(example::taskA).start();
        new Thread(example::taskB).start();
    }
}
```

以上示例展示了CountDownLatch用于线程间的等待通知，以及Semaphore用于控制对共享资源的访问。