Java多线程：并发工具类如Semaphore的示例

原创傷城~ 2024-10-21 08:42 27阅读 0赞

在Java中，`java.util.concurrent`包提供了许多用于管理并发的工具类。其中，`Semaphore`就是一个典型的信号量，它可以限制同时访问某个资源的数量。

下面是一个简单的示例，展示如何使用`Semaphore`来控制两个线程对同一资源的访问：

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

public class SemaphoreExample {

// 创建一个信号量，初始值为2
    private Semaphore semaphore = new Semaphore(2);

public void thread1() {
        try {
            semaphore.acquire(); // 请求使用资源
            System.out.println("Thread 1 is processing..."); // 主线程执行任务
            // ...这里可以添加你的代码逻辑

semaphore.release(); // 释放信号量，表示资源可用
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public void thread2() {
        try {
            semaphore.acquire(); // 请求使用资源
            System.out.println("Thread 2 is processing..."); // 主线程执行任务
            // ...这里可以添加你的代码逻辑

semaphore.release(); // 释放信号量，表示资源可用
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

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

Thread thread1 = new Thread(example::thread1));
        Thread thread2 = new Thread(example::thread2));

thread1.start(); // 启动线程1
        thread2.start(); // 启动线程2

// 等待所有线程执行完毕
        thread1.join();
        thread2.join();
    }
}
```

在这个例子中，`Semaphore`用来控制同时访问资源的线程数量。线程1和线程2分别尝试获取资源并执行任务，但因为信号量限制，它们不能同时进行。