当前位置：首页 > news >正文

Java面试必看！Semaphore的作用及实战案例解析！

news 2026/3/27 2:00:42

文章目录

Java面试必看！Semaphore的作用及实战案例解析！
- 引言
- 一、Semaphore的基本概念
- - 1.1 什么是Semaphore？
  - 1.2 Semaphore的工作原理
- 二、Semaphore的核心方法
- - 2.1 acquire() 方法
  - 2.2 release() 方法
  - 2.3 getQueueLength() 方法
  - 2.4 availablePermits() 方法
- 三、Semaphore的应用场景
- - 3.1 控制并发数
  - 3.2 替代ReentrantLock
  - 3.3 实现信号量机制
- 四、总结
- 希望本文能够帮助大家更好地理解和使用Java中的`Semaphore`！
- - 📚 领取 | 1000+ 套高质量面试题大合集（无套路，闫工带你飞一把）！

Java面试必看！Semaphore的作用及实战案例解析！

引言

各位小伙伴们，大家好啊！闫工又来给大家讲解Java面试中的知识点啦！今天咱们要聊的是一个非常重要的同步工具——** Semaphore（信号量）**。这可是Java多线程编程中不可或缺的一部分，掌握它不仅能让你在面试中脱颖而出，还能在实际开发中游刃有余。

相信很多小伙伴都听说过Semaphore这个词，但可能对它的具体作用和使用场景还不是很清楚。没关系，今天闫工就带着大家一起深入了解 Semaphore 的前世今生，从理论到实战，手把手教大家如何玩转这个强大的工具！

一、Semaphore的基本概念

1.1 什么是Semaphore？

Semaphore（信号量）是Java中用于控制同时访问特定资源的线程数量的一种同步工具。它就像一个交通警察，负责协调多个线程对共享资源的访问，确保系统的稳定性和高效性。

在多线程编程中，我们经常需要限制某些资源的并发访问数，比如数据库连接池、文件读写操作等。Semaphore就可以很好地解决这个问题，它可以控制同时访问这些资源的线程数量，从而避免资源被过度使用或者发生竞争。

1.2 Semaphore的工作原理

Semaphore的核心思想是基于许可（permits）机制。每个信号量都有一个固定的许可数量，当线程想要访问受控资源时，必须先获取一个许可；如果所有许可都被占用，那么该线程就会被阻塞，直到有其他线程释放许可。

举个简单的例子：假设我们有一个Semaphore对象，初始化时设置为3。这意味着最多允许3个线程同时访问某个资源。当第4个线程试图访问这个资源时，它会被阻塞，直到其中一个线程释放许可为止。

二、Semaphore的核心方法

在Java中，Semaphore类位于java.util.concurrent包下，提供了以下几个核心方法：

2.1 acquire() 方法

publicvoidacquire()throwsInterruptedException

作用：尝试获取一个许可。如果没有可用的许可，线程会被阻塞，直到有其他线程释放许可。
异常：如果当前线程被中断，则会抛出InterruptedException。

2.2 release() 方法

publicvoidrelease()

作用：释放一个许可，使得其他等待的线程可以继续执行。

2.3 getQueueLength() 方法

publicintgetQueueLength()

作用：返回正在等待获取许可的线程数量。

2.4 availablePermits() 方法

publicintavailablePermits()

作用：返回当前可用的许可数量。

三、Semaphore的应用场景

Semaphore在实际开发中有着广泛的应用，以下是几个常见的使用场景：

3.1 控制并发数

最常见的应用场景就是控制系统的并发线程数。例如，在数据库连接池中，我们通常会限制同时访问数据库的线程数量，以避免服务器过载。

示例代码：

importjava.util.concurrent.Semaphore;publicclassDatabaseConnection{privatestaticfinalintMAX_CONNECTIONS=5;privatestaticSemaphoresemaphore=newSemaphore(MAX_CONNECTIONS);publicvoidgetConnection(){try{// 尝试获取一个许可，最多等待10秒if(semaphore.tryAcquire(10,TimeUnit.SECONDS)){System.out.println(Thread.currentThread().getName()+" 获取到数据库连接");// 模拟数据库操作Thread.sleep(2000);semaphore.release();// 释放许可}else{System.out.println(Thread.currentThread().getName()+" 获取数据库连接超时，放弃请求");}}catch(InterruptedExceptione){Thread.currentThread().interrupt();System.out.println(Thread.currentThread().getName()+" 被中断，退出获取连接操作");}}publicstaticvoidmain(String[]args){DatabaseConnectiondb=newDatabaseConnection();for(inti=0;i<10;i++){Threadthread=newThread(db::getConnection,"Thread-"+i);thread.start();}}}

解释：

我们创建了一个Semaphore对象，初始化时设置为5个许可。
每个线程调用getConnection()方法尝试获取一个许可。最多只能有5个线程同时访问数据库。
如果某个线程在10秒内没有获得许可，则会放弃请求。

3.2 替代ReentrantLock

Semaphore还可以用来替代ReentrantLock，实现更灵活的锁机制。

示例代码：

importjava.util.concurrent.Semaphore;publicclassCounter{privateintcount=0;privateSemaphoresemaphore=newSemaphore(1);// 初始化为1个许可publicvoidincrement(){try{semaphore.acquire();// 获取锁count++;System.out.println(Thread.currentThread().getName()+" 增加到："+count);Thread.sleep(1000);// 模拟操作时间semaphore.release();// 释放锁}catch(InterruptedExceptione){Thread.currentThread().interrupt();System.out.println(Thread.currentThread().getName()+" 被中断，退出");}}publicstaticvoidmain(String[]args){Countercounter=newCounter();for(inti=0;i<5;i++){Threadthread=newThread(counter::increment,"Thread-"+i);thread.start();}}}

解释：

我们使用Semaphore来实现互斥锁，确保只有一个线程可以执行increment()方法。
这个示例展示了如何将Semaphore作为互斥锁的替代品。

3.3 实现信号量机制

Semaphore最经典的用途就是实现信号量机制。例如，在操作系统中，多个进程需要共享某个资源时，可以通过信号量来协调它们的行为。

示例代码：

importjava.util.concurrent.Semaphore;publicclassSignalExample{privatestaticfinalSemaphoreavailableSem=newSemaphore(0);// 初始没有可用的许可privatestaticfinalSemaphorebusySem=newSemaphore(1);// 初始有一个许可publicstaticvoidmain(String[]args){// 创建生产者线程ThreadproducerThread=newThread(()->{for(inti=0;i<5;i++){try{System.out.println("生产者正在生产...");busySem.acquire();// 等待消费者释放许可availableSem.release();// 通知消费者可以消费了Thread.sleep(100);// 模拟生产时间}catch(InterruptedExceptione){Thread.currentThread().interrupt();System.out.println("生产者被中断，退出");}}},"Producer");// 创建消费者线程ThreadconsumerThread=newThread(()->{for(inti=0;i<5;i++){try{availableSem.acquire();// 等待生产者的通知System.out.println("消费者正在消费...");busySem.release();// 通知生产者可以继续生产了Thread.sleep(100);// 模拟消费时间}catch(InterruptedExceptione){Thread.currentThread().interrupt();System.out.println("消费者被中断，退出");}}},"Consumer");producerThread.start();consumerThread.start();}}