Java并发编程实战：Semaphore使用场景示例

原创 r囧r小猫 2024-09-17 00:12 59阅读 0赞

Semaphore（信号量）是Java中并发工具包的一部分，用于控制对共享资源的访问。它主要应用于以下几种场景：

1. **线程互斥**：当多个线程需要同时访问一个资源时，可以使用Semaphore来限制同一时刻最多有多少个线程可以访问。

```java
Semaphore permit = new Semaphore(1); // 初始化信号量为1

// 线程1进入临界区
Thread t1 = new Thread(() -> {
    try {
        permit.acquire(); // 获取信号量
        // 访问共享资源
        System.out.println("Thread 1 is processing...");
        // 经过一定时间后释放信号量
        // 通常用来模拟资源的有限性
        // TimeUnit.SECONDS.sleep(5);
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        permit.release(); // 释放信号量
        System.out.println("Thread 1 is done.");
    }
}));

// 线程2进入临界区
Thread t2 = new Thread(() -> {
    try {
        permit.acquire(); // 获取信号量
        // 访问共享资源
        System.out.println("Thread 2 is processing...");
        // 经过一定时间后释放信号量
        TimeUnit.SECONDS.sleep(5);
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        permit.release(); // 释放信号量
        System.out.println("Thread 2 is done.");
    }
}));

t1.start();
t2.start();

// 等待两个线程都完成
Thread.join(t1);
Thread.join(t2);
```

2. **资源分组**：当一组资源需要由一定数量的线程共同访问时，Semaphore可以用来控制每个线程同时访问的资源个数。

3. **信号量定时任务**：通过设置信号量的值并使用`wait()`和`signal()`方法，可以创建一个定时任务，即在规定的时间间隔后，允许一组线程访问某个资源。

以上就是Semaphore在Java并发编程中的常见使用场景。