多线程同步：Java中的Semaphore使用示例

原创﹏ヽ暗。殇╰゛Y 2024-11-21 04:51 23阅读 0赞

在Java中，`Semaphore`是线程同步的一种工具，它允许固定数量的并发线程访问共享资源。

以下是一个简单的`Semaphore`使用示例：

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

public class SemaphoreExample {
    private Semaphore permit = new Semaphore(1); // 初始化许可值为1

public void threadAction() throws InterruptedException {
        // 线程试图获取一个大于0的许可
        if (permit.tryAcquire()) {
            System.out.println("Thread " + Thread.currentThread().getName() + " is allowed to access resource.");
            // 执行耗时操作
            performTimeConsumingTask();
        } else {
            System.out.println("Thread " + Thread.currentThread().getName() + " couldn't acquire permit. Wait and try again.");
        }
    }

private void performTimeConsumingTask() {
        try {
            Thread.sleep(2000); // 模拟耗时操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        Thread thread1 = new Thread(example::threadAction, "Thread 1"));
        Thread thread2 = new Thread(example::threadAction, "Thread 2"));

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

// 等待所有线程完成执行
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，我们创建了两个`Semaphore`，每个初始许可值为1。两个线程尝试获取这些许可。

如果一个线程能够成功获取许可（tryAcquire()返回true），它就可以执行耗时的操作，然后释放许可供其他线程使用。

这个例子展示了`Semaphore`如何有效地控制多个并发线程的访问权限。