使用阻塞队列BlockingQueue实现生产者消费者

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 ]