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(); } } }
上面的代码创建了一个Semaphore对象,并指定许可的数量为3。然后创建了10个线程,每个线程在执行之前先获取一个许可,如果许可不可用,线程将被阻塞。执行完任务后,释放许可,以便其它线程可以获取许可继续执行。
运行上面的代码,你会发现最多只有3个线程同时在执行,其它线程会被阻塞,等待许可的释放。这样可以有效地控制对共享资源的访问。