Java多线程通信：信号量和条件变量示例

原创我就是我 2024-11-27 07:51 2阅读 0赞

在Java中，多线程的通信机制主要有两种：信号量（Semaphore）和条件变量（Condition Variable）。

1. 信号量示例：
```java
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private final Semaphore permit = new Semaphore(1);

public void acquire() throws InterruptedException {
        permit.acquire();
    }

public void release() {
        permit.release();
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();

// 创建两个线程
        Thread t1 = new Thread(() -> {
            try {
                example.acquire(); // 请求许可
                System.out.println("Thread 1: Inside the semaphore.");
                example.release(); // 释放许可
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread t2 = new Thread(() -> {
            try {
                example.acquire(); // 请求许可
                System.out.println("Thread 2: Inside the semaphore.");
                example.release(); // 释放许可
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        t1.start();
        t2.start();

// 等待所有线程执行完毕
        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Semaphore released by main thread.");
    }
}
```
在这个示例中，我们创建了一个`Semaphore`，初始许可为1。两个线程`t1`和`t2`分别尝试获取许可并执行相应代码。

当一个线程请求许可且资源可用时，它将获得许可并执行。当线程释放其占用的许可证时，该许可证可用于其他需要的线程。

这个示例展示了如何在Java中使用信号量进行多线程通信。