一、Semaphore概念

Semaphore是Java并发编程中比较重要的一种同步辅助类,它可以控制同时访问特定资源的线程数量,它通过协调各个线程,以保证合理的使用公共资源,保证多个线程的有序运行。Semaphore可以控制某个资源可被同时访问的个数,通过 acquire() 获取一个许可,如果没有就等待,而 release() 释放一个许可。

二、Semaphore示例

下面以一个简单的示例来说明Semaphore的用法,模拟一个停车场,其最大车位数为3,有4辆车来停车:

public class SemaphoreDemo {

public static void main(String[] args) {

Semaphore semaphore = new Semaphore(3); // 模拟3个停车位

for (int i = 1; i <= 6; i++) { // 模拟6部汽车

new Thread(() -> {

try {

semaphore.acquire(); // 获取一个许可

System.out.println(Thread.currentThread().getName() + "\t 抢到车位");

TimeUnit.SECONDS.sleep(3); // 停车3秒钟

System.out.println(Thread.currentThread().getName() + "\t 停车3秒后离开车位");

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

semaphore.release(); // 释放许可

}

}, String.valueOf(i)).start();

}

}

}

三、Semaphore使用场景

Semaphore适用于控制资源访问的场景,比如:池、队列、缓存等,比如:

1、数据库连接池:数据库连接池的大小通常是有限的,使用Semaphore来控制并发的访问数量,以保证数据库连接池不被淹没。

2、文件访问:文件有时候也会存在并发访问的情况,可以使用Semaphore来控制并发的访问数量,以保证文件的完整性。

3、缓存访问:缓存也会存在并发访问的情况,可以使用Semaphore来控制并发的访问数量,以保证缓存的完整性。