信号量在Java中主要用于控制共享资源的并发访问数量，其核心原理是通过维护许可计数器限制线程访问。1. 初始化时设定许可数量，代表可用资源数；2. 线程调用acquire()获取许可，若许可充足则继续执行并减少计数器，否则阻塞等待；3. 线程完成任务后调用release()释放许可，唤醒等待线程。公平性可通过构造函数设置，确保请求顺序或允许插队。使用示例中通过semaphore限制最多3个线程并发执行任务，模拟了数据库连接池等场景。与锁相比，semaphore更通用，支持多线程访问而非仅单一线程。为避免死锁，需注意获取顺序一致、设置超时机制及异常下资源释放。应用场景包括流量控制、资源限制及有界队列实现，帮助构建高效稳定的并发程序。
信号量在Java中主要用于控制对共享资源的并发访问数量，就像交通信号灯控制道路上的车辆数量一样，确保资源不会因为过度并发而崩溃。它通过维护一个许可计数器来实现这一点，线程必须先获取许可才能访问资源，访问完毕释放许可。
Semaphore限制并发数的原理
Semaphore的核心在于它的许可（permit）计数器。初始化时，你可以设置这个计数器的初始值，代表可用的许可数量。
立即学习“Java免费学习笔记（深入）”；
- 获取许可（acquire）： 当一个线程想要访问共享资源时，它会尝试调用acquire()方法来获取一个许可。
- 如果许可计数器大于0，线程成功获取许可，计数器减1。线程可以继续执行。
- 如果许可计数器等于0，线程会被阻塞，直到有其他线程释放许可。
- 释放许可（release）： 当线程完成对共享资源的访问后，它会调用release()方法来释放许可。
- 许可计数器加1。
- 如果有其他线程因为等待许可而被阻塞，那么其中一个线程会被唤醒，并获取许可继续执行。
Semaphore的公平性可以通过构造函数指定。公平信号量会按照线程请求许可的顺序来分配许可，而非公平信号量则允许“插队”，即如果一个线程恰好在许可可用时尝试获取，即使有其他线程在等待，它也可能先获取到许可。
Java中如何使用Semaphore？
import java.util.concurrent.Semaphore; public class SemaphoreExample { private static final int MAX_PERMITS = 3; // 最大并发数 private static Semaphore semaphore = new Semaphore(MAX_PERMITS, true); // 公平锁 public static void main(String[] args) { for (int i = 0; i < 10; i++) { new Thread(new Task(i)).start(); } } static class Task implements Runnable { private int taskId; public Task(int taskId) { this.taskId = taskId; } @Override public void run() { try { System.out.println("Thread " + taskId + " is waiting for permit."); semaphore.acquire(); System.out.println("Thread " + taskId + " acquired permit."); // 模拟耗时操作 Thread.sleep((long) (Math.random() * 1000)); System.out.println("Thread " + taskId + " is releasing permit."); semaphore.release(); } catch (InterruptedException e) { e.printStackTrace(); } } } }
在这个例子中，我们创建了一个最多允许3个线程同时访问的信号量。每个线程在执行任务前都需要先获取许可，执行完毕后释放许可。
Semaphore与锁（Lock）的区别是什么？
锁（例如ReentrantLock）通常用于保护临界区，确保同一时间只有一个线程可以访问。Semaphore则更通用，它可以控制多个线程同时访问共享资源的数量。锁本质上是许可数量为1的信号量。
假设你有一个数据库连接池，你希望限制同时连接到数据库的线程数量，这时Semaphore就非常有用。而如果你只是想保护一个共享变量，防止并发修改，那么锁可能更合适。
如何避免Semaphore的死锁问题？
死锁是并发编程中常见的问题，Semaphore也不例外。要避免死锁，需要注意以下几点：
- 避免循环等待： 线程获取多个信号量的顺序要一致。如果线程A先获取信号量S1，再获取S2，那么其他线程也应该遵循相同的顺序。
- 设置超时时间： acquire()方法有带超时时间的版本，例如acquire(long timeout, TimeUnit unit)。如果线程在指定时间内没有获取到许可，可以放弃等待，避免永久阻塞。
- 资源释放： 确保在任何情况下，线程都能释放已经获取的信号量，即使发生异常。可以使用try-finally块来保证释放操作的执行。
try { semaphore.acquire(); // ... 执行操作 ... } catch (InterruptedException e) { // ... 处理中断 ... } finally { semaphore.release(); }
Semaphore在实际开发中的应用场景有哪些？
除了数据库连接池，Semaphore还可以用于：
总的来说，Semaphore是一个强大的并发控制工具，理解它的原理和使用方法，可以帮助你编写更健壮、更高效的并发程序。当然，并发编程本身就比较复杂，需要仔细考虑各种边界情况和潜在的问题。
