Java多线程Semaphore工具怎么使用

76次阅读

共计 885 个字符，预计需要花费 3 分钟才能阅读完成。

Semaphore 是 Java 多线程中的一个重要工具，用于控制多个线程对共享资源的访问。Semaphore 可以被看作是一个计数信号量，控制同时访问某个资源的线程个数。

Semaphore 的常用方法有以下几个：

acquire(): 获取一个许可，如果没有许可可用，线程将阻塞，直到有一个许可可用。
release(): 释放一个许可，使其它线程可以获取许可。如果有阻塞的线程正在等待许可，将会选择其中一个线程获取许可。

下面是一个使用 Semaphore 的示例代码：

import java.util.concurrent.Semaphore;

public class SemaphoreExample {public static void main(String[] args) {// 创建 Semaphore 对象，指定许可的数量为 3 
        Semaphore semaphore = new Semaphore(3);

        // 创建 10 个线程 
        for (int i = 0; i < 10; i++) {final int threadNum = i;
            new Thread(() -> {try {// 获取许可 
                    semaphore.acquire();
                    System.out.println("Thread " + threadNum + " is running");
                    Thread.sleep(1000);
                    System.out.println("Thread " + threadNum + " is finished");
                } catch (InterruptedException e) {e.printStackTrace();
                } finally {// 释放许可 
                    semaphore.release();}
            }).start();}
    }
}