轉(zhuǎn)載請(qǐng)標(biāo)明出處：http://blog.csdn.net/zhaoyanjun6/article/details/120833494
本文出自【趙彥軍的博客】

Java隊(duì)列 Queue
Java隊(duì)列 Deque
Java隊(duì)列 PriorityQueue
Java棧 Stack
Java阻塞隊(duì)列 LinkedBlockingDeque

文章目錄

• LinkedBlockingDeque
• 源碼
• • 增加操作
  • 刪除操作
  • 訪問操作
• BlockingQueue
• 核心要點(diǎn)
• 實(shí)戰(zhàn)

LinkedBlockingDeque

LinkedBlockingDeque類實(shí)現(xiàn)了BlockingDeque接口。閱讀BlockingDeque文本以獲取有關(guān)的更多信息。

Deque來自“雙端隊(duì)列” 這個(gè)詞。Deque是一個(gè)隊(duì)列，你可以在插入和刪除隊(duì)列兩端的元素。

LinkedBlockingDeque是一個(gè)Deque，如果一個(gè)線程試圖從中獲取一個(gè)元素，而隊(duì)列空的，不管線程從哪一端試圖獲取元素，都會(huì)被阻塞。

以下是實(shí)例化和使用LinkedBlockingDeque的例子：

BlockingDeque<String> deque = new LinkedBlockingDeque<String>();deque.addFirst("1"); deque.addLast("2");String two = deque.takeLast(); String one = deque.takeFirst();

LinkedBlockingDeque的底層數(shù)據(jù)結(jié)構(gòu)是一個(gè)雙端隊(duì)列，該隊(duì)列使用鏈表實(shí)現(xiàn)，其結(jié)構(gòu)圖如下：

源碼

LinkedBlockingDeque與LinkedBlockingQueue的實(shí)現(xiàn)大體上類似，區(qū)別在于LinkedBlockingDeque提供的操作更多。并且LinkedBlockingQueue內(nèi)置兩個(gè)鎖分別用于put和take操作，而LinkedBlockingDeque只使用一個(gè)鎖控制所有操作。因?yàn)殛?duì)列能夠同時(shí)在頭尾進(jìn)行put和take操作，所以使用兩個(gè)鎖也需要將兩個(gè)鎖同時(shí)加鎖才能保證操作的同步性，不如只使用一個(gè)鎖的性能好。

同步節(jié)點(diǎn)相比LinkedBlockingQueue多了一個(gè)prev字段。

static final class Node<E> {E item;Node<E> prev;Node<E> next;Node(E x) {item = x;} }

增加操作

增加操作相比LinkedBlockingQueue只能在隊(duì)列尾部增加，它能在隊(duì)列的頭尾兩端都進(jìn)行增加操作。

public void addFirst(E e) {// 復(fù)用offer方法if (!offerFirst(e))throw new IllegalStateException("Deque full"); }public void addLast(E e) {if (!offerLast(e))throw new IllegalStateException("Deque full"); }public boolean offerFirst(E e) {if (e == null) throw new NullPointerException();// 構(gòu)造節(jié)點(diǎn)Node<E> node = new Node<E>(e);final ReentrantLock lock = this.lock;lock.lock();try {// 插入到隊(duì)列頭部return linkFirst(node);} finally {lock.unlock();} }private boolean linkFirst(Node<E> node) {// assert lock.isHeldByCurrentThread();// 如果隊(duì)列已滿，返回falseif (count >= capacity)return false;// 獲取頭節(jié)點(diǎn)，將自己的 next字段指向頭節(jié)點(diǎn)，然后設(shè)置自己為頭節(jié)點(diǎn)Node<E> f = first;node.next = f;first = node;// 如果隊(duì)列為空，尾節(jié)點(diǎn)也指向自己if (last == null)last = node;elsef.prev = node;++count;// 喚醒等待獲取元素的線程notEmpty.signal();return true; }public boolean offerLast(E e) {if (e == null) throw new NullPointerException();Node<E> node = new Node<E>(e);final ReentrantLock lock = this.lock;lock.lock();try {// 插入到隊(duì)列尾部return linkLast(node);} finally {lock.unlock();} }private boolean linkLast(Node<E> node) {// assert lock.isHeldByCurrentThread();// 如果隊(duì)列已滿，返回falseif (count >= capacity)return false;// 將自己設(shè)置為尾節(jié)點(diǎn)Node<E> l = last;node.prev = l;last = node;// 如果隊(duì)列為空，頭節(jié)點(diǎn)也指向自己if (first == null)first = node;elsel.next = node;++count;// 喚醒等待獲取元素的線程notEmpty.signal();return true; }public void putFirst(E e) throws InterruptedException {if (e == null) throw new NullPointerException();Node<E> node = new Node<E>(e);final ReentrantLock lock = this.lock;lock.lock();try {// 如果隊(duì)列已滿，等待while (!linkFirst(node))notFull.await();} finally {lock.unlock();} }public void putLast(E e) throws InterruptedException {if (e == null) throw new NullPointerException();Node<E> node = new Node<E>(e);final ReentrantLock lock = this.lock;lock.lock();try {// 如果隊(duì)列已滿，等待while (!linkLast(node))notFull.await();} finally {lock.unlock();} }public boolean offerFirst(E e, long timeout, TimeUnit unit)throws InterruptedException {if (e == null) throw new NullPointerException();Node<E> node = new Node<E>(e);// 計(jì)算超時(shí)時(shí)間long nanos = unit.toNanos(timeout);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {// 如果隊(duì)列已滿，超時(shí)等待while (!linkFirst(node)) {if (nanos <= 0L)return false;nanos = notFull.awaitNanos(nanos);}return true;} finally {lock.unlock();} }public boolean offerLast(E e, long timeout, TimeUnit unit)throws InterruptedException {if (e == null) throw new NullPointerException();Node<E> node = new Node<E>(e);long nanos = unit.toNanos(timeout);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {while (!linkLast(node)) {if (nanos <= 0L)return false;nanos = notFull.awaitNanos(nanos);}return true;} finally {lock.unlock();} }

刪除操作

public E removeFirst() {// 復(fù)用poll操作E x = pollFirst();if (x == null) throw new NoSuchElementException();return x; }public E removeLast() {E x = pollLast();if (x == null) throw new NoSuchElementException();return x; }public E pollFirst() {final ReentrantLock lock = this.lock;lock.lock();try {// 獲取頭節(jié)點(diǎn)的值，并刪除它return unlinkFirst();} finally {lock.unlock();} }private E unlinkFirst() {// assert lock.isHeldByCurrentThread();// 如果隊(duì)列為空，返回nullNode<E> f = first;if (f == null)return null;// 重置頭節(jié)點(diǎn)Node<E> n = f.next;E item = f.item;f.item = null;f.next = f; // help GCfirst = n;if (n == null)last = null;elsen.prev = null;--count;// 喚醒等待插入的線程notFull.signal();return item; }public E pollLast() {final ReentrantLock lock = this.lock;lock.lock();try {return unlinkLast();} finally {lock.unlock();} }private E unlinkLast() {// assert lock.isHeldByCurrentThread();Node<E> l = last;// 隊(duì)列為空，返回nullif (l == null)return null;// 更新尾節(jié)點(diǎn)Node<E> p = l.prev;E item = l.item;l.item = null;l.prev = l; // help GClast = p;if (p == null)first = null;elsep.next = null;--count;notFull.signal();return item; }public E takeFirst() throws InterruptedException {final ReentrantLock lock = this.lock;lock.lock();try {E x;// 如果隊(duì)列為空，等待while ( (x = unlinkFirst()) == null)notEmpty.await();return x;} finally {lock.unlock();} }public E takeLast() throws InterruptedException {final ReentrantLock lock = this.lock;lock.lock();try {E x;// 如果隊(duì)列為空，等待while ( (x = unlinkLast()) == null)notEmpty.await();return x;} finally {lock.unlock();} }public E pollFirst(long timeout, TimeUnit unit)throws InterruptedException {long nanos = unit.toNanos(timeout);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {E x;while ( (x = unlinkFirst()) == null) {if (nanos <= 0L)return null;nanos = notEmpty.awaitNanos(nanos);}return x;} finally {lock.unlock();} }public E pollLast(long timeout, TimeUnit unit)throws InterruptedException {long nanos = unit.toNanos(timeout);final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {E x;while ( (x = unlinkLast()) == null) {if (nanos <= 0L)return null;nanos = notEmpty.awaitNanos(nanos);}return x;} finally {lock.unlock();} }

訪問操作

public E getFirst() {// 復(fù)用peek方法E x = peekFirst();if (x == null) throw new NoSuchElementException();return x; }public E getLast() {E x = peekLast();if (x == null) throw new NoSuchElementException();return x; }public E peekFirst() {final ReentrantLock lock = this.lock;lock.lock();try {// 如果隊(duì)列不為空，返回頭元素return (first == null) ? null : first.item;} finally {lock.unlock();} }public E peekLast() {final ReentrantLock lock = this.lock;lock.lock();try {// 如果隊(duì)列不為空，返回尾元素return (last == null) ? null : last.item;} finally {lock.unlock();} }

BlockingQueue

由于BlockingDeque繼承自BlockingQueue接口，所以需要實(shí)現(xiàn)BlockingQueue中的方法，具體只需要復(fù)用前面提到的方法即可。

public boolean add(E e) {addLast(e);return true; }public boolean offer(E e) {return offerLast(e); }public void put(E e) throws InterruptedException {putLast(e); }public boolean offer(E e, long timeout, TimeUnit unit)throws InterruptedException {return offerLast(e, timeout, unit); }public E remove() {return removeFirst(); }public E poll() {return pollFirst(); }public E take() throws InterruptedException {return takeFirst(); }public E poll(long timeout, TimeUnit unit) throws InterruptedException {return pollFirst(timeout, unit); }public E element() {return getFirst(); }public E peek() {return peekFirst(); }

核心要點(diǎn)

• LinkedBlockingDeque 是基于鏈表的雙端阻塞隊(duì)列,線程安全,元素不允許為 null
• 內(nèi)部使用一個(gè)雙向鏈表
• 可以在鏈表兩頭同時(shí)進(jìn)行put和take操作，只能使用一個(gè)鎖
• 插入線程在執(zhí)行完操作后如果隊(duì)列未滿會(huì)喚醒其他等待插入的線程，同時(shí)隊(duì)列非空還會(huì)喚醒等待獲取元素的線程；take線程同理。
• 迭代器與內(nèi)部的雙向鏈表保持弱一致性，調(diào)用 remove(T) 方法刪除一個(gè)元素后，不會(huì)解除其對(duì)下一個(gè)結(jié)點(diǎn)的next引用，否則迭代器將無法工作。
• 迭代器的forEachRemaining(Consumer<? super E> action)以64個(gè)元素為一批進(jìn)行操作
• forEach(Consumer<? super E> action)，removeIf，removeAll，retainAll都是64個(gè)元素為一批進(jìn)行操作

實(shí)戰(zhàn)

因?yàn)?LinkedBlockingDeque 取出是阻塞的，所以可以做一個(gè) 生產(chǎn)-消費(fèi) 模型

package zyj;import java.util.concurrent.BlockingDeque; import java.util.concurrent.LinkedBlockingDeque;public class Product {//指定隊(duì)列最大值為100BlockingDeque<Apple> deque = new LinkedBlockingDeque(100);//生產(chǎn)，如果隊(duì)列滿了，則拋出 IllegalStateExceptionpublic void produce(Apple apple) {deque.push(apple);}//消費(fèi)，如果隊(duì)列為空，則線程阻塞public Apple consume() {try {return deque.take();} catch (InterruptedException e) {e.printStackTrace();}return null;} }

總結(jié)

以上是生活随笔為你收集整理的Java阻塞队列 LinkedBlockingDeque的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。