java.util.concurrent – Java 并发工具

翻译自http://tutorials.jenkov.com/java-util-concurrent/index.html

相关文章：

• java.util.concurrent - Java 并发工具包 二

Java 5 添加了一个新java包到Java平台，java.util.concurrent。这个包含有一系列的类使通过Java来开发并发（多线程）应用程序更为简单方便。在这个包被添加前你不得不自己创建相关工具类。

一、BlockingQueue 阻塞队列

java.util.concurrent里面的BlockingQueue接口代表一个线程安全的队列。
BlockingQueue通常用于一个线程生成对象，另一个线程消费。

生产线程持续生成新的对象并且把它插入都队列直到队列达到它容纳的上限。如果这个阻塞队列达到容量上限，生产线程再尝试插入新的对象时会阻塞。它会一直阻塞直到一个消费线程从队列中取走一个对象。

消费线程会持续从阻塞队列中取出对象然后处理它们。如果一个消费线程尝试从一个空的队列中取对象，它就会被阻塞直到一个生产线程向队列中放入一个对象为止。

1.1 BlockingQueue方法

BlockingQueue有4套不同的方法集合来插入、删除；2套方法来检查队列中的元素。每套不同方法的行为取决于请求的操作是否立即执行。这4套方法的区别是：

1. Throws Exception 如果企图的操作不可能立即完成，那么会抛出一个异常。
2. Special Value 如果企图的操作不可能立即完成，那么会返回一个特殊的值（通常是true/false）。
3. Blocks 如果企图的操作不可能立即完成，这个方法会阻塞，直到可以继续进行。
4. Times Out 如果企图的操作不可能立即完成，这个方法会阻塞，但是阻塞的时间最长不会超过指定的timeout值，达到timeout后会返回一个特殊的值（通常是true/false）来告诉你操作是否成功。

一个线程生产元素并且可以将它们插入队列的两端。如果双端队列当前是满的，这个插入线程将会被阻塞直到一个消费线程从队列取出一个元素，当消费线程从中取的时候也是类似的情况。

2.2 BlockingDeque方法

BlockingDeque有4种不同系列的方法用来插入、删除和检查在双端队列中的元素。

这四套不同的行为如下，与BlockingQueue类似：

1. Throws Exception 如果企图的操作不可能立即完成，那么会抛出一个异常。
2. Special Value 如果企图的操作不可能立即完成，那么会返回一个特殊的值（通常是true/false）。
3. Blocks 如果企图的操作不可能立即完成，这个方法会阻塞，直到可以继续进行。
4. Times Out 如果企图的操作不可能立即完成，这个方法会阻塞，但是阻塞的时间最长不会超过指定的timeout值，达到timeout后会返回一个特殊的值（通常是true/false）来告诉你操作是否成功。

2.3 BlockingDeque继承自BlockingQueue

BlockingDeque接口继承自BlockingQueue接口。这意味这你可以将BlockingDeque当作BlockingQueue用。

下面是一个表格来展示BlockingQueue的方法在BlockingDeque的实现里是如何工作的：

2.4 BlockingDeque实现类

既然BlockingDeque是一个接口，你就需要使用它的某个实现类。java.util.concurrent包有以下实现类：

LinkedBlockingDeque

2.5 BlockingDeque代码示例

下面是一个简单的例子来展示如何使用它的方法：

BlockingDeque<String> deque = new LinkedBlockingDeque<String>();

deque.addFirst("1");
deque.addLast("2");

String two = deque.takeLast();
String one = deque.takeFirst();