Java多线程Semaphore工具怎么使用

avatar
作者
猴君
阅读量:0

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个线程同时在执行,其它线程会被阻塞,等待许可的释放。这样可以有效地控制对共享资源的访问。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!