Java线程同步工具Lock和Semaphore的使用示例

原创爱被打了一巴掌 2024-09-27 15:45 76阅读 0赞

在Java中，Lock和Semaphore都是用于线程同步的工具。下面分别给出它们的使用示例：

1. Lock（无界锁）：
   - 使用简单，适用于不需要限定并发数量的情况。
   - 示例代码如下：

```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class LockExample {
    private final Lock lock = new ReentrantLock();

public void methodThatRequiresSync() {
        // 确保当前线程获得了锁
        lock.lock();
        try {
            // 在锁保护的代码块中执行操作
            System.out.println("Method is executing under lock");
        } finally {
            // 无论是否出现异常，都要释放锁
            lock.unlock();
        }
    }

public static void main(String[] args) {
        LockExample example = new LockExample();
        example.methodThatRequiresSync();
    }
}
```

2. Semaphore（信号量）：
   - 提供了一个有限的并发控制机制，当到达信号量的最大值时，后续线程将被阻塞。
   - 示例代码如下：

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

public class SemaphoreExample {
    private final Semaphore semaphore = new Semaphore(3); // 初始化为最大值

public void methodThatRequiresSemaphore() throws InterruptedException {
        semaphore.acquire(); // 请求信号量，如果未达到最大值则成功获取
        try {
            System.out.println("Method is executing under semaphore");
        } finally {
            // 无论是否出现异常，都要释放信号量
            semaphore.release();
        }
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        try {
            example.methodThatRequiresSemaphore();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

以上示例展示了如何使用Lock和Semaphore这两种线程同步工具。