Semaphore是Java多线程中的一个重要工具,用于控制多个线程对共享资源的访问。Semaphore可以被看作是一个计数信号量,控制同时访问某个资源的线程个数。
Semaphore的常用方法有以下几个:
下面是一个使用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个线程同时在执行,其它线程会被阻塞,等待许可的释放。这样可以有效地控制对共享资源的访问。