一、应用背景
通常情况下，我们会在线程之间进行通信。一个线程产生数据，另一个线程则取出数据进行相关的业务逻辑处理。类似于生产者或消费者。在软件设计中通常会将各个模块做的尽量独立，基于这种情况，生产者可以将数据写入到一个中间数据结构中，而消费者可以从这个中间数据结构中取出数据进行消费，实现了软件间的松耦合。而java.util.concurrent包下有很多阻塞队列可以帮助我们实现，我们就选取ArrayBlocking进行测验
二、代码实战
我们就以生产者和消费者为例子进行测试
package concurrent; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.TimeUnit; public class ArrayBlockingQueueTest { private ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(10); public static void main(String[] args) throws InterruptedException { final ArrayBlockingQueueTest arrayBlockingQueueTest = new ArrayBlockingQueueTest(); new Thread(new Runnable() { public void run() { try { arrayBlockingQueueTest.producer(); } catch (InterruptedException e) { e.printStackTrace(); } } }).start(); new Thread(new Runnable() { public void run() { try { arrayBlockingQueueTest.consumer(); } catch (InterruptedException e) { e.printStackTrace(); } } }).start(); } private void producer() throws InterruptedException { for(int i=0; i<100; i++) { System.out.println("arrayBlockingQueue.size()="+arrayBlockingQueue.size()); //Thread.sleep(1000); //队列满了之后会直接抛出异常 //arrayBlockingQueue.add(i); //队列满了之后会等待队列腾出空间 //arrayBlockingQueue.put(i); //将指定的元素插入到此队列的尾部（如果立即可行且不会超过该队列的容量），在成功时返回 true，如果此队列已满，则返回 false。 arrayBlockingQueue.offer(i); } } private void consumer() throws InterruptedException { while(true) { //Thread.sleep(1000); //获取并移除此队列的头部，在指定的等待时间前等待可用的元素。如果已经没有可用的元素，则没10s返回一个null // System.out.println(arrayBlockingQueue.poll(10000, TimeUnit.MILLISECONDS)); //获取并移除此队列的头部，在元素变得可用之前一直等待 System.out.println(arrayBlockingQueue.take()); //获取但不移除此队列的头；如果此队列为空，则返回 null //System.out.println(arrayBlockingQueue.peek()); } } }关于队列中各方法的说明：
操作 抛出异常 返回某个特殊值 一直阻塞到队列可用 一定时间后退出 操作方式 添加元素 add(e) offer(e) put(e) offer(e,time,unit) 添加到队尾 移除元素 remove() poll() take() poll(e,time,unit) 获取头元素并移除 查询元素 element() peek() 无 无 获取头元素但不移除
