生产者-消费者模式是一种并发设计模式，主要用于处理在多线程环境下数据共享和同步的问题。它涉及到两类线程：生产者（负责生成数据）和消费者（负责使用数据）。为了避免潜在的冲突和不一致性，通常会有一个缓冲区（队列）作为中介。
关键特点
-
缓冲区：通常是一个阻塞队列，用来存放生产者创建的数据项。
-
同步机制：确保多个线程在访问共享资源时不会相互干扰，例如通过使用锁（synchronized blocks, ReentrantLock）和条件变量（wait/notify, Condition）。
-
平衡工作负载：当生产者工作得比消费者快时，缓冲区将积累数据；而当消费者工作得比生产者快时，缓冲区将变空，消费者可能会等待。
好处
-
解耦合：生产者和消费者的独立性提高了代码的可维护性。
-
灵活性：可以根据需要独立地调整生产者和消费者的数量和速度。
-
效率：同时运行的生产者和消费者可以提高程序整体的吞吐量。
Java实例
以下是使用java.util.concurrent包中的ArrayBlockingQueue来实现生产者-消费者模式的示例。ArrayBlockingQueue是一个由数组支持的有界阻塞队列，这意味着它具有固定的容量，并且提供了线程安全的插入和移除操作。
import java.util.concurrent.BlockingQueue;import java.util.concurrent.ArrayBlockingQueue;class Producer implements Runnable {private final BlockingQueue<Integer> queue;Producer(BlockingQueue<Integer> q) { queue = q; }public void run() {try {for (int i = 0; true; i++) {queue.put(i);System.out.println("Produced " + i);Thread.sleep((int) (Math.random() * 1000)); // 模拟耗时的生产过程}} catch (InterruptedException ex) {Thread.currentThread().interrupt();}}}class Consumer implements Runnable {private final BlockingQueue<Integer> queue;Consumer(BlockingQueue<Integer> q) { queue = q; }public void run() {try {while (true) {int take = queue.take();System.out.println("Consumed " + take);Thread.sleep((int) (Math.random() * 1000)); // 模拟耗时的消费过程}} catch (InterruptedException ex) {Thread.currentThread().interrupt();}}}public class ProducerConsumerExample {public static void main(String[] args) {BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);Producer producer = new Producer(queue);Consumer consumer = new Consumer(queue);new Thread(producer).start();new Thread(consumer).start();// 这里可以添加更多的生产者和消费者}}
在上述代码中：
-
Producer类实现了Runnable接口，其run方法将生产的项目放入队列。
-
Consumer类同样实现了Runnable接口，其run方法从队列中取出项目并消费（在这里仅打印到控制台）。
-
main方法中创建了一个有界阻塞队列，然后创建了生产者和消费者实例，并分别在新线程中启动它们。
注意：在实际应用中，你通常会有多个生产者和消费者线程同时运行。此外，为了适应中断并正确地关闭线程，我们在异常处理中加入了对线程中断状态的检查。
关注我，每天一道面试。
本篇文章来源于微信公众号: 互联网面试小帮手
微信扫描下方的二维码阅读本文
Comments NOTHING