使用Java编写的多线程通信问题实例

原创素颜马尾好姑娘i 2024-09-23 00:01 52阅读 0赞

在Java中，多线程通信通常通过共享数据结构（如 synchronized 的变量）或者使用特定的通信机制（如 Condition Variable、Semaphore等）来实现。

以下是一个简单的多线程通信示例，使用了java.util.concurrent包下的ConditionVariable：

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

public class MultiThreadCommunication {
    private final Lock lock = new ReentrantLock();
    private final Condition condition = lock.newCondition();

private int count = 0;

public void producer() {
        lock.lock();
        try {
            while (count < 3) { // 模拟生产数据
                condition.await(); // 等待条件满足
            }

System.out.println("Producer produced data: " + count++); // 生产并更新数据

condition.signalAll(); // 发信号，唤醒所有等待的线程
        } finally {
            lock.unlock();
        }
    }

public void consumer() {
        lock.lock();
        try {
            while (count < 3) { // 模拟消费数据
                condition.await(); // 等待条件满足
            }

System.out.println("Consumer consumed data: " + count++); // 消费并更新数据

condition.signalAll(); // 发信号，唤醒所有等待的线程
        } finally {
            lock.unlock();
        }
    }

public static void main(String[] args) {
        MultiThreadCommunication mtc = new MultiThreadCommunication();

Thread producerThread = new Thread(mtc::producer);
        Thread consumerThread = new Thread(mtc::consumer);

producerThread.start();
        consumerThread.start();

try {
            // 等待所有线程完成
            producerThread.join();
            consumerThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，生产者（producerThread）和消费者（consumerThread）通过共享数据（count变量）来进行通信。当count达到3时，生产者才会开始生产数据，并更新count。消费者则在count达到3后消费数据并更新count。