深入理解Java并发工具类（如Semaphore）的使用及其常见问题

原创小灰灰 2024-09-23 00:15 77阅读 0赞

Java并发工具类，如`Semaphore`，是一种线程同步机制，主要用于控制同时访问资源的线程数量。

1. `Semaphore`的基本用法：
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(1); // 创建一个允许一次进入的信号量

public void threadA() {
        try {
            semaphore.acquire(); // 请求获得信号量
            System.out.println("Thread A: Access granted, doing something..."); // 执行任务
            Thread.sleep(2000); // 等待一段时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            try {
                semaphore.release(); // 释放信号量，允许其他线程进入
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

public void threadB() {
        try {
            semaphore.acquire(); // 请求获得信号量
            System.out.println("Thread B: Access granted, doing something..."); // 执行任务
            Thread.sleep(5000); // 等待一段时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            try {
                semaphore.release(); // 释放信号量，允许其他线程进入
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

public static void main(String[] args) {
        Thread threadA = new Thread(new SemaphoreExample().threadA()));
        Thread threadB = new Thread(new SemaphoreExample().threadB()));

threadA.start();
        threadB.start();
    }
}
```
2. 常见问题：
- **过度同步**：信号量过于严格，可能导致其他线程无法执行任务。
- **忘记释放信号量**：如果线程正常结束，可能会忘记释放信号量，导致信号量数量不一致，其他线程无法访问资源。
- **死锁**：当多个线程相互等待对方释放资源时，可能会陷入死锁状态。可以使用`Semaphore`的`newCondition()`方法创建一个新条件，用于处理死锁情况。