Java多线程Semaphore工具怎么使用

   2025-01-31 5790
核心提示:Semaphore是Java多线程中的一个重要工具,用于控制多个线程对共享资源的访问。Semaphore可以被看作是一个计数信号量,控制同时访

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

 
 
更多>同类维修知识
推荐图文
推荐维修知识
点击排行
网站首页  |  关于我们  |  联系方式  |  用户协议  |  隐私政策  |  网站留言