1、生产者消费者模型一般用于将复杂的业务逻辑异步化,多个线程来同时处理以提升系统的运行效率,典型的案例就是消息队列。
2、这里我使用的是blockingqueue,java提供的一种阻塞队列的实现,用来简单的实现生产者消费者模型。
3、生产者代码
public class Producer implements Runnable { private BlockingQueue<String> blockingQueue; public Producer() { } public Producer(BlockingQueue<String> blockingQueue) { this.blockingQueue = blockingQueue; } public void run() { try { String temp = "生产线程" + Thread.currentThread().getName(); blockingQueue.put(temp); } catch (InterruptedException e) { e.printStackTrace(); } } }
4、消费者代码
public class Consumer implements Runnable { private BlockingQueue<String> blockingQueue; public Consumer() { } public Consumer(BlockingQueue<String> blockingQueue) { this.blockingQueue = blockingQueue; } public void run() { try { // 取出阻塞队列中的消息 String temp = blockingQueue.take(); // 打印结果消息 System.out.println("消费线程"+Thread.currentThread().getName()+" 消费 "+temp); } catch (Exception e) { e.printStackTrace(); } } }
5、测试代码
public class ProducerConsumerTest { public static void main(String[] args) { BlockingQueue<String> blockingQueue = new LinkedBlockingQueue<String>(); Producer producer = new Producer(blockingQueue); Consumer consumer = new Consumer(blockingQueue); for(int i = 0; i < 5; i++){ //生产者线程 new Thread(producer).start(); //消费者线程 new Thread(consumer).start(); } } }