在Java中如何使用Semaphore控制并发访问_Semaphore类实践经验-java教程-PHP中文网

在Java中如何使用Semaphore控制并发访问_Semaphore类实践经验

P粉602998670

发布： 2025-11-16 15:36:40

原创

750人浏览过

Semaphore用于控制并发线程数，通过acquire获取许可、release释放许可，确保最多n个线程访问资源，适用于限流与资源池管理，需注意公平性选择、finally中释放许可及避免中断处理遗漏。

在java中如何使用semaphore控制并发访问_semaphore类实践经验

在Java并发编程中，Semaphore 是一个非常有用的工具类，位于 java.util.concurrent 包下，主要用于控制同时访问某一资源的线程数量。它通过维护一组许可证（permits）来实现对资源的限制，适合用于限流、资源池管理等场景。

理解Semaphore的基本原理

Semaphore可以看作是一个信号灯，用来控制可同时运行的线程数。当一个线程想要访问共享资源时，需要先获取一个许可（acquire），如果当前没有可用许可，线程就会被阻塞，直到其他线程释放许可（release）。

关键点：

许可数量：初始化时指定最多允许多少个线程并发执行。
公平性：可选择是否采用公平策略（先等待的线程优先获得许可）。
acquire()：获取一个或多个许可，可能阻塞。
release()：释放一个或多个许可，不阻塞。

基本使用示例：限制并发线程数

假设我们有一个服务接口，最多只允许3个线程同时调用，可以用Semaphore进行控制：

立即学习“Java免费学习笔记（深入）”；

import java.util.concurrent.Semaphore;

public class ServiceWithSemaphore {
    private final Semaphore semaphore = new Semaphore(3); // 最多3个并发

    public void handleRequest() throws InterruptedException {
        semaphore.acquire(); // 获取许可
        try {
            System.out.println(Thread.currentThread().getName() + " 开始处理任务");
            Thread.sleep(2000); // 模拟耗时操作
            System.out.println(Thread.currentThread().getName() + " 完成任务");
        } finally {
            semaphore.release(); // 释放许可
        }
    }

    public static void main(String[] args) {
        ServiceWithSemaphore service = new ServiceWithSemaphore();
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                try {
                    service.handleRequest();
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }, "Thread-" + i).start();
        }
    }
}

登录后复制

在这个例子中，尽管启动了10个线程，但每次只有3个能真正进入执行状态，其余线程会等待许可释放。