了解Semaphore吗？

### 了解Semaphore #### 什么是Semaphore？ Semaphore（信号量）是一种用于控制对某个资源的访问线程数的机制。它通过维护一个许可计数器来限制某段代码块的并发访问数量。当某段代码需要被访问时，线程必须先从Semaphore获取许可，只有在获取许可成功后才能进入该代码块。使用完毕后，线程必须释放许可。 #### 核心作用 - **限制并发数**：通过设定一个最大并发数，控制同时访问某段代码的线程数。 - **同步控制**：可以用来实现复杂的同步控制，比如限制对某些资源的并发访问，或者实现资源池等。 #### 主要方法 - **acquire()**：获取一个许可，如果没有可用的许可，则线程进入等待状态，直到有许可可用。 - **release()**：释放一个许可，唤醒等待的线程。 - **availablePermits()**：返回当前可用的许可数。 - **tryAcquire()**：尝试获取一个许可，立即返回，不会进入等待状态。 #### 示例代码 以下是一个使用Semaphore的简单示例，展示了如何限制某段代码的并发访问数量： ```java import java.util.concurrent.Semaphore; public class SemaphoreExample { private final Semaphore semaphore; public SemaphoreExample(int permits) { this.semaphore = new Semaphore(permits); } public void doTask() { try { semaphore.acquire(); // 获取许可 System.out.println(Thread.currentThread().getName() + " is executing task."); Thread.sleep(2000); // 模拟任务执行 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } finally { semaphore.release(); // 释放许可 } } public static void main(String[] args) { final SemaphoreExample example = new SemaphoreExample(3); // 限制最多3个线程同时访问 for (int i = 0; i < 10; i++) { new Thread(() -> { example.doTask(); }).start(); } } } ``` #### 使用场景 - **资源池管理**：限制对有限资源（如数据库连接）的并发访问。 - **限流控制**：控制同时执行的任务数量，防止过载。 - **多生产者-多消费者模型**：在生产者和消费者之间进行流量控制。 #### 特殊情况 - 如果Semaphore构造函数中的许可数为1，则相当于一个互斥锁，只有一个线程可以访问该代码段。 ### 总结 - **Semaphore** 是一种用于控制并发访问资源数量的机制。 - 通过 `acquire()` 和 `release()` 方法来获取和释放许可，从而限制并发线程数。 - 适用于资源池管理、限流控制、多生产者-多消费者模型等场景。 - 构造函数中的许可数可以灵活设置，决定了同时访问该资源的最大线程数。 Semaphore在并发编程中非常有用，可以有效控制对共享资源的访问数量，避免资源竞争和过载。