Java多线程通信机制：Message Passing Case Study

原创 Love The Way You Lie 2024-10-10 07:30 25阅读 0赞

在Java多线程通信中，Message Passing（消息传递）是一种常见的沟通方式。下面我们将通过一个案例来详细理解Java多线程通信中的Message Passing。

案例：生产者-消费者模型

1. **创建两个线程**：
   - 生产者（Producer）线程：负责产生产品（消息），然后放入队列。
   - 消费者（Consumer）线程：负责从队列中取出产品（消息），并进行处理。

2. **设计数据结构**：
   - 队列（Queue）：用于存储生产者产生的产品。

3. **编写多线程代码**：

```java
// 1. 创建两个线程类
public class ProducerThread extends Thread {
    private Queue<String> queue;

public ProducerThread(Queue<String> queue) {
        this.queue = queue;
    }

@Override
    public void run() {
        // 生产产品（消息）
        for (int i = 0; i < 10; i++) {
            String product = "Product " + i;
            // 将产品放入队列
            queue.add(product);
            System.out.println("Producer added: " + product);
            try {
                Thread.sleep(50); // 模拟生产过程中的延迟
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class ConsumerThread extends Thread {
    private Queue<String> queue;

public ConsumerThread(Queue<String> queue) {
        this.queue = queue;
    }

@Override
    public void run() {
        while (true) { // 模拟无尽循环，直到停止
            // 从队列中取出产品（消息）
            String product = queue.poll();
            if (product == null) { // 如果队列为空，则跳出循环
                System.out.println("Consumer thread: No products available");
                break;
            }

System.out.println("Consumer thread received: " + product);
            try {
                Thread.sleep(100); // 模拟处理过程中的延时
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

// 2. 创建队列对象
Queue<String> queue = new LinkedList<>();

// 3. 启动线程
ProducerThread producer = new ProducerThread(queue);
producer.start();

ConsumerThread consumer = new ConsumerThread(queue);
consumer.start();
```

通过这个案例，你可以看到Java多线程通信中，Message Passing是如何实现生产者-消费者模型的。