Java多线程基础（11）- Semaphore的使用详解

2023-10-15 06:17:02

在多线程编程中，如何有效地控制对共享资源的访问是一个关键问题。Java提供了多种同步机制来解决这一问题，其中Semaphore（信号量）是一种非常实用的方法。本文将详细介绍Semaphore的使用方法及其在不同场景下的应用。

Semaphore概述

Semaphore（信号量）是一种用于控制对共享资源访问的同步工具。它通过一个计数器来管理对资源的访问，计数器的值表示可用的资源数量。当线程需要访问资源时，必须先获取信号量；如果信号量的计数器大于0，则线程可以继续执行并减少计数器；如果计数器为0，则线程必须等待，直到有其他线程释放信号量。

Semaphore的用法

在Java中，Semaphore类提供了以下几个主要方法：

Semaphore(int permits): 构造函数，指定初始的许可证数量。
acquire(): 尝试获取一个许可证，如果没有可用的许可证，则线程阻塞直到有许可证可用。
release(): 释放一个许可证，使其可供其他线程使用。

Semaphore示例

下面是一个简单的Semaphore示例，展示了如何使用Semaphore来控制对共享资源的访问：

import java.util.concurrent.Semaphore;

public class SemaphoreExample {

    private static final Semaphore semaphore = new Semaphore(1);

    public static void main(String[] args) {
        Thread thread1 = new Thread(() -> {
            try {
                semaphore.acquire();
                System.out.println("Thread 1 acquired the semaphore");
                Thread.sleep(1000);
                semaphore.release();
                System.out.println("Thread 1 released the semaphore");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        Thread thread2 = new Thread(() -> {
            try {
                semaphore.acquire();
                System.out.println("Thread 2 acquired the semaphore");
                Thread.sleep(1000);
                semaphore.release();
                System.out.println("Thread 2 released the semaphore");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        thread1.start();
        thread2.start();
    }
}