温馨提示×

Java多线程Semaphore工具怎么使用

小亿
98
2024-01-25 13:32:29
栏目: 编程语言

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

0