Java多线程同步问题：信号量使用示例

原创布满荆棘的人生 2024-12-13 19:18 5阅读 0赞

在Java中，`Semaphore`是Java并发工具包中的一个类，用于控制同时访问某个资源的线程数量。下面是一个简单的`Semaphore`使用示例：

```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1); // 初始化为最多1个线程

public void threadOne() {
        try {
            semaphore.acquire(); // 获取信号量，表示允许一个线程进入资源区
            System.out.println("Thread 1 is executing ..."); // 线程执行代码
            semaphore.release(); // 释放信号量，表示允许其他线程进入资源区
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public void threadTwo() {
        try {
            semaphore.acquire(); // 线程需要获取信号量才能进入资源区
            System.out.println("Thread 2 is executing ..."); // 线程执行代码
            semaphore.release(); // 释放信号量，表示允许其他线程进入资源区
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        Thread threadOne = new Thread(example::threadOne);
        Thread threadTwo = new Thread(example::threadTwo);

threadOne.start(); // 启动线程1
        threadTwo.start(); // 启动线程2

// 等待所有线程执行完毕
        threadOne.join();
        threadTwo.join();

System.out.println("Example finished ..."); // 执行完后，输出一条消息
    }
}
```

这个示例中，我们创建了两个并发线程`threadOne`和`threadTwo`。每个线程都需要通过信号量来控制对共享资源的访问。

在`main`方法中，我们启动了这两个线程，并等待它们执行完毕。最后输出一条消息表示示例结束。