深入理解Java并发工具类：Semaphore、CountDownLatch等实例分析

原创 - 日理万妓 2024-09-26 05:51 79阅读 0赞

在Java编程中，理解和使用一些并发工具类如Semaphore和CountDownLatch是非常重要的。下面我们将通过实例来深入理解这两种工具。

1. Semaphore（信号量）：
Semaphore是一种同步原语，它只允许固定数量的线程同时访问某个资源。当一个线程请求访问资源而资源已被占用时，该线程会被阻塞，等待资源可用。

实例分析：

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

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1);

public void allowAccess() {
        semaphore.acquire();
        System.out.println("Access granted to one thread");
    }

public void denyAccess() {
        semaphore.acquire();
        System.out.println("Access denied to all threads");
        semaphore.release(); // Releasing the acquired semaphore
    }

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

// Thread 1: Allow access
        new Thread(() -> example.allowAccess()).start();

// Thread 2: Deny access (should be blocked)
        new Thread(() -> example.denyAccess()).start();
    }
}
```

在上述代码中，SemaphoreExample类包含一个Semaphore对象。allowAccess方法允许一个线程访问资源，denyAccess方法尝试禁止所有线程访问资源。

2. CountDownLatch（计数器）：
CountDownLatch是一个同步原语，它有一个初始值，并提供一个方法来减少这个值。当一个或多个等待该事件的线程看到countdown latch的count减到零时，它们会释放已持有的锁并继续执行。

实例分析：

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

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

public void signal() {
        countDownLatch.countDown();
        System.out.println("Signal received, counting down");
    }

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

// Thread 1: Signal
        new Thread(() -> example.signal()).start();

// Wait for signal to be received
        try {
            countDownLatch.await();
            System.out.println("All threads have waited and signal received");
        } catch (InterruptedException e) {
            System.out.println("Interrupted while waiting for signal");
            e.printStackTrace();
        }
    }
}
```

在上述代码中，CountDownLatchExample类包含一个CountDownLatch对象。signal方法用于向等待该事件的线程发出信号。main方法创建了CountDownLatchExample实例，并通过两个线程进行交互。

通过以上实例分析，您可以更好地理解和应用Java并发工具类Semaphore和CountDownLatch。