深入理解Java并发：生产者-消费者问题实战案例

原创比眉伴天荒 2024-10-22 19:27 15阅读 0赞

生产者-消费者问题（P-C Problem）是并发编程中的经典问题，它模拟了生产者向特定的缓冲区中放入产品，而消费者从该缓冲区中取出产品的过程。

以下是一个使用Java实现生产者-消费者问题的实战案例：

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

public class PCProblem {

// 创建一个固定大小的缓冲队列
    private static final int BUFFER_SIZE = 10;
    private static BlockingQueue<String> queue = new ArrayBlockingQueue<>(BUFFER_SIZE);

public static void main(String[] args) {
        // 生产者线程
        Thread producerThread = new Thread(() -> produce(queue));
        producerThread.start();

// 消费者线程
        Thread consumerThread = new Thread(() -> consume(queue)));
        consumerThread.start();
    }

// 生产者方法
    private static void produce(BlockingQueue<String> queue) {
        for (int i = 0; i < 20; i++) {
            try {
                queue.put("Product " + i);
                System.out.println("Produced: " + "Product " + i);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

// 消费者方法
    private static void consume(BlockingQueue<String> queue) {
        for (int i = 0; i < 15; i++) {
            try {
                String product = queue.take();
                System.out.println("Consumed: " + product);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if (i == 7) { // 模拟生产者停止
                System.out.println("Producer stopped!");
                break;
            }
        }
    }
}
```

这个案例中，生产者线程不断地向缓冲队列放入产品（"Product " + i）；消费者线程则不断地从缓冲队列取出并消费产品。

当生产者线程模拟停止时，会输出一条信息。