BlockingQueue有一组阻塞的方法:
put() 方法:当队列容量达到最大,自动阻塞
take() 方法:当队列容量为0,自动阻塞
使用 BlockingQueue实现的生产者消费者简单测试代码如下:
package com.cjy.concurrent; import java.util.concurrent.LinkedBlockingQueue; class Producer extends Thread{ LinkedBlockingQueue<String> queue; public Producer(LinkedBlockingQueue<String> queue) { this.queue = queue; } @Override public void run() { try { int i = 0; for (int k = 20; k > 0; k--) { System.out.println("生产者生产产品:" + String.valueOf(i)+" [队列大小:"+queue.size()+"]"); queue.put(String.valueOf(i)); i++; } } catch (InterruptedException e) { e.printStackTrace(); } } } class Consumer extends Thread { LinkedBlockingQueue<String> queue; public Consumer(LinkedBlockingQueue<String> queue) { this.queue = queue; } @Override public void run() { try { for (int j = 20; j > 0; j--) { String s = (String) queue.take(); System.out.println("**消费者消费产品***: " + s+" [队列大小:"+queue.size()+"]"); } } catch (InterruptedException e) { e.printStackTrace(); } } } public class ProducterCustomer { public static LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(3); public static void main(String[] args) { Producer producer = new Producer(queue); Consumer consumer = new Consumer(queue); ((Producer) producer).start(); ((Consumer) consumer).start(); } }
测试结果:
生产者生产产品:0 [ 队列大小:0 ] 生产者生产产品:1 [ 队列大小:1 ] 生产者生产产品:2 [ 队列大小:1 ] **消费者消费产品***: 0 [ 队列大小:1 ] **消费者消费产品***: 1 [ 队列大小:1 ] 生产者生产产品:3 [ 队列大小:2 ] **消费者消费产品***: 2 [ 队列大小:0 ] 生产者生产产品:4 [ 队列大小:1 ] **消费者消费产品***: 3 [ 队列大小:0 ] 生产者生产产品:5 [ 队列大小:1 ] **消费者消费产品***: 4 [ 队列大小:0 ] **消费者消费产品***: 5 [ 队列大小:0 ] 生产者生产产品:6 [ 队列大小:1 ] 生产者生产产品:7 [ 队列大小:1 ] 生产者生产产品:8 [ 队列大小:1 ] 生产者生产产品:9 [ 队列大小:2 ] **消费者消费产品***: 6 [ 队列大小:0 ] 生产者生产产品:10 [ 队列大小:3 ] 生产者生产产品:11 [ 队列大小:3 ] **消费者消费产品***: 7 [ 队列大小:2 ] **消费者消费产品***: 8 [ 队列大小:2 ] 生产者生产产品:12 [ 队列大小:3 ] **消费者消费产品***: 9 [ 队列大小:2 ] **消费者消费产品***: 10 [ 队列大小:2 ] 生产者生产产品:13 [ 队列大小:3 ] 生产者生产产品:14 [ 队列大小:2 ] 生产者生产产品:15 [ 队列大小:3 ] **消费者消费产品***: 11 [ 队列大小:1 ] **消费者消费产品***: 12 [ 队列大小:2 ] 生产者生产产品:16 [ 队列大小:2 ] 生产者生产产品:17 [ 队列大小:3 ] **消费者消费产品***: 13 [ 队列大小:2 ] **消费者消费产品***: 14 [ 队列大小:2 ] **消费者消费产品***: 15 [ 队列大小:1 ] 生产者生产产品:18 [ 队列大小:2 ] 生产者生产产品:19 [ 队列大小:2 ] **消费者消费产品***: 16 [ 队列大小:1 ] **消费者消费产品***: 17 [ 队列大小:2 ] **消费者消费产品***: 18 [ 队列大小:1 ] **消费者消费产品***: 19 [ 队列大小:0 ]