多线程同步工具：Semaphore应用示例-蒲公英云

多线程同步工具：Semaphore应用示例

原创梦里梦外; 2024-09-13 00:45 137阅读 0赞

Semaphore（信号量）是Java中用于多线程同步的一种工具。它类似于硬件中的锁，可以限制同时访问特定资源的线程数量。

以下是一个Semaphore应用的简单示例：

import java.util.concurrent.Semaphore;
public class SemaphoreExample {
    private Semaphore mutex = new Semaphore(1); // 创建一个初始许可量为1的信号量
    public void threadA() {
        try {
            mutex.acquire(); // 获取锁，如果当前没有可用许可量，则会阻塞直到有许可量可用
            System.out.println("Thread A is running..."); // 执行线程任务
            mutex.release(); // 释放锁，表示任务执行完毕可以由其他线程访问资源了
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    public void threadB() {
        try {
            mutex.acquire(); // 获取锁
            System.out.println("Thread B is running..."); // 执行线程任务
            mutex.release(); // 释放锁，表示任务执行完毕可以由其他线程访问资源了
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        Thread threadA = new Thread(example::threadA));
        Thread threadB = new Thread(example::threadB));
        threadA.start(); // 启动线程A
        threadB.start(); // 启动线程B
        // 等待所有线程执行完毕
        threadA.join();
        threadB.join();
        System.out.println("All threads have finished running."); // 所有线程执行完毕后输出的消息
    }
}