Java多线程同步问题：Locks与Semaphores实例

原创喜欢ヅ旅行 2024-10-24 00:36 29阅读 0赞

在Java中，Locks和Semaphores都是用来实现多线程同步的工具。下面我们将它们以实例形式进行说明。

1. Locks（互斥锁）：
```java
// 使用ReentrantLock创建对象
private final Lock lock = new ReentrantLock();

// 示例：一个方法只允许一次调用
public void criticalSection() {
    lock.lock(); // 获取锁
    try {
        // 执行代码，这里假设是耗时操作
        System.out.println("Critical section is running...");

// 需要手动释放锁，才能让其他线程进入
        lock.unlock(); // 释放锁
    } catch (Exception e) {
        e.printStackTrace();
    }
}
```
2. Semaphores（信号量）：
在Java中，原生库并没直接提供SignalSemaphore的API。但是可以使用CountDownLatch或CyclicBarrier来模拟信号量的行为。

例如，我们可以通过CountDownLatch模拟一个资源的计数器：

```java
// 创建一个资源计数器
private final CountDownLatch resourceCounter = new CountDownLatch(1);

// 示例：一个方法允许多个线程同时访问资源
public void criticalSection() {
    // 线程调用资源，会增加资源计数
    resourceCounter.countDown();

// 这里假设执行耗时操作
    try {
        Thread.sleep(2000); // 耗时操作，模拟资源占用时间
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

// 多个线程同时调用criticalSection方法
public class Main {
    public static void main(String[] args) {
        for (int i = 0; i < 5; i++) {
            new Thread(() -> criticalSection()).start();
        }
    }
}
```
以上例子展示了如何使用Locks（互斥锁）和模拟的CountDownLatch来实现多线程同步。