消费者生产者模式（2）——用java阻塞队列实现

本文主要是介绍消费者生产者模式（2）——用java阻塞队列实现，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

    生产者——消费者模式有三个阶段的编程：

    1.使用synchronized,wait,notify（这在我博客中已经有实现了，可以找找看看）

     2.使用阻塞队列LinkedBlockingQueue（这是本小节的重点）

     3.使用非阻塞式的内存结构如ConcurrentLinkedQueue（以后补充）

     本小节所讨论的生产者消费者模式是通过一个容器来解决的。生产者和消费者彼此之间不直接通信，而通过阻塞队列来进行通信，所以生产者生产完数据之后不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列中获取，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力。

     这个阻塞队列就是用来给生产者和消费者解耦的。纵观大多数设计模式，都会找一个第三者出来进行解耦，如工厂模式的第三者是工厂类。

下面我就用阻塞队列LinkedBlockingQueue来实现生产者消费者模式:

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;public class ProducerConsumer {public static void main(String[] args) {BlockingQueue sharedQueue = new LinkedBlockingQueue();Thread prodThread = new Thread(new Producer(sharedQueue));Thread consThread = new Thread(new Consumer(sharedQueue));prodThread.start();consThread.start();}
}class Producer implements Runnable {private final BlockingQueue sharedQueue;public Producer (BlockingQueue sharedQueue) {this.sharedQueue = sharedQueue;}@Overridepublic void run() {for(int i = 0; i < 10; i++) {try {System.out.println("Produced: "+ i);sharedQueue.put(i);} catch (InterruptedException ex) {ex.printStackTrace();}}}
}class Consumer implements Runnable {private final BlockingQueue sharedQueue;public Consumer (BlockingQueue sharedQueue) {this.sharedQueue = sharedQueue;}@Overridepublic void run() {for(int i = 0; i < 10; i++) {try {System.out.println("Consumerd: "+ i);sharedQueue.take();} catch (InterruptedException ex) {ex.printStackTrace();}}}
}

运行结果：

Produced: 0
Consumerd: 0
Produced: 1
Consumerd: 1
Produced: 2
Consumerd: 2
Produced: 3
Consumerd: 3
Produced: 4
Consumerd: 4
Produced: 5
Consumerd: 5
Produced: 6
Consumerd: 6
Produced: 7
Consumerd: 7
Produced: 8
Consumerd: 8
Produced: 9
Consumerd: 9

     

这篇关于消费者生产者模式（2）——用java阻塞队列实现的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---