信号量在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来控制队列的容量，防止队列无限增长。
总的来说，Semaphore是一个强大的并发控制工具，理解它的原理和使用方法，可以帮助你编写更健壮、更高效的并发程序。当然，并发编程本身就比较复杂，需要仔细考虑各种边界情况和潜在的问题。
