Java并发编程：生产者-消费者模型示例

原创 ╰+哭是因爲堅強的太久メ 2024-09-13 05:42 82阅读 0赞

在Java中，生产者-消费者（Producer-Consumer）模型是一种常见的并发问题。下面是一个简单的示例：

```java
import java.util.concurrent.*;

// 生产者类
class Producer {
    private final BlockingQueue<String> queue;
    private int count;

public Producer(BlockingQueue<String> queue) {
        this.queue = queue;
    }

public void produce() throws InterruptedException {
        for (int i = 0; i < 10; i++) {
            System.out.println("Producer: Producing " + i);
            queue.put("Task-" + i); // 添加任务到队列
            count++;
            if (count % 5 == 0) { // 每5个生产周期检查
                System.out.println("Producer: Checking... (" + count + ")");
                Thread.sleep(1000); // 暂停一段时间，模拟耗时操作
            }
        }
    }
}

// 消费者类
class Consumer {
    private final BlockingQueue<String> queue;

public Consumer(BlockingQueue<String> queue) {
        this.queue = queue;
    }

public void consume() throws InterruptedException {
        while (!queue.isEmpty()) {
            System.out.println("Consumer: Consuming " + queue.take());
        }
    }
}

public class PCModelExample {
    public static void main(String[] args) {
        // 创建生产者和消费者
        BlockingQueue<String> queue = new LinkedBlockingQueue<>(10); // 设置队列容量
        Producer producer = new Producer(queue);
        Consumer consumer = new Consumer(queue);

// 启动生产者和消费者
        Thread producerThread = new Thread(producer::produce);
        Thread consumerThread = new Thread(consumer::consume);
        producerThread.start();
        consumerThread.start();

// 等待所有线程完成
        producerThread.join();
        consumerThread.join();
    }
}
```

这个示例中，生产者负责生产任务（模拟为字符串"Task-"后跟数字），并将这些任务放入共享的队列。消费者则从队列中取出任务进行处理。

这个模型通过Java并发库中的`BlockingQueue`实现同步和公平性。