Java多线程同步问题：Semaphore使用案例

原创你的名字 2024-10-23 16:03 43阅读 0赞

在Java中，Semaphore是一种信号量工具，用于控制对共享资源的访问。它主要用于多线程环境下，防止因并发过高导致的资源冲突。

以下是一个Semaphore使用案例：

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

public class SemaphoreDemo {
    private Semaphore semaphore = new Semaphore(3); // 初始化信号量，初始值为3

public void thread1() {
        try {
            semaphore.acquire(); // 请求信号量，如果已满则会阻塞到被唤醒
            System.out.println("Thread 1 is running ..."); // 执行任务
            semaphore.release(); // 释放信号量，表示任务已完成，其他线程可以继续请求信号量
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public void thread2() {
        try {
            semaphore.acquire(); // 请求信号量，如果已满则会阻塞到被唤醒
            System.out.println("Thread 2 is running ..."); // 执行任务
            semaphore.release(); // 释放信号量，表示任务已完成，其他线程可以继续请求信号量
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        SemaphoreDemo demo = new SemaphoreDemo();
        Thread thread1 = new Thread(demo::thread1));
        Thread thread2 = new Thread(demo::thread2));

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

// 线程执行完毕后，主线程会等待
    }
}
```

在这个例子中，Semaphore用于控制两个线程（Thread 1 和 Thread 2）对共享资源（这里我们假设是一个计数器）的访问。当计数器达到3时，线程将被阻塞，直到有其他线程释放了信号量，它们才能继续执行。