ArrayBlockingQueue和LinkedBlockingQueue最大的區別是一個是有界無界，各有優劣。

先看實例代碼：

main函數起2個線程模擬生成消費者

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;public class BlockingQueueExample {public static void main(String[] args) throws Exception {BlockingQueue queue = new ArrayBlockingQueue(1024);//BlockingQueue queue = new LinkedBlockingQueue(1024);Producer producer = new Producer(queue);Consumer consumer = new Consumer(queue);new Thread(producer).start();new Thread(consumer).start();Thread.sleep(4000);}
}

生產者：?

public class Producer implements Runnable{protected BlockingQueue queue = null;public Producer(BlockingQueue queue) {this.queue = queue;}public void run() {try {queue.put("1>>> "+DateUtil.getNowTimeString());Thread.sleep(1000);queue.put("2>>> "+DateUtil.getNowTimeString());Thread.sleep(5000);queue.put("3>>> "+DateUtil.getNowTimeString());} catch (InterruptedException e) {e.printStackTrace();}}
}

消費者：?

public class Consumer implements Runnable{protected BlockingQueue queue = null;public Consumer(BlockingQueue queue) {this.queue = queue;}public void run() {try {System.out.println(queue.take()+" "+DateUtil.getNowTimeString());System.out.println(queue.take()+" "+DateUtil.getNowTimeString());System.out.println(queue.take()+" "+DateUtil.getNowTimeString());} catch (InterruptedException e) {e.printStackTrace();}}
}

數據量少的情況下LinkedBlockingQueue差別不大。

?

二者的類圖：

LinkedBlockingQueue源碼初始化默認不指定大小就使用Integer.MAX_VALUE配置的默認值：

/*** Creates a {@code LinkedBlockingQueue} with a capacity of* {@link Integer#MAX_VALUE}.*/public LinkedBlockingQueue() {this(Integer.MAX_VALUE);}

LinkedBlockingQueue中的鎖是分離的，生產者的鎖putLock，消費者的鎖takeLock?

?ArrayBlockingQueue生產者和消費者使用的是同一把鎖ReentrantLock lock：

put:?

take:?

https://stackoverflow.com/questions/18375334/what-is-the-difference-between-arrayblockingqueue-and-linkedblockingqueue

https://stackoverflow.com/questions/35967792/when-to-prefer-linkedblockingqueue-over-arrayblockingqueue

?

關于二者的異同參考下面的這個總結的還不錯：LinkedBlockingQueue和ArrayBlockingQueue的異同

相同：

LinkedBlockingQueue和ArrayBlockingQueue都是可阻塞的隊列

內部都是使用ReentrantLock和Condition來保證生產和消費的同步；

當隊列為空，消費者線程被阻塞；當隊列裝滿，生產者線程被阻塞；

使用Condition的方法來同步和通信：await()和signal()

不同：

1、鎖機制不同

　　LinkedBlockingQueue中的鎖是分離的，生產者的鎖PutLock，消費者的鎖takeLock

　　而ArrayBlockingQueue生產者和消費者使用的是同一把鎖；

2、底層實現機制也不同

　　LinkedBlockingQueue內部維護的是一個鏈表結構。

在生產和消費的時候，需要創建Node對象進行插入或移除，大批量數據的系統中，其對于GC的壓力會比較大。

　　而ArrayBlockingQueue內部維護了一個數組

在生產和消費的時候，是直接將枚舉對象插入或移除的，不會產生或銷毀任何額外的對象實例。

3、構造時候的區別

　　LinkedBlockingQueue有默認的容量大小為：Integer.MAX_VALUE，當然也可以傳入指定的容量大小

ArrayBlockingQueue在初始化的時候，必須傳入一個容量大小的值

4、執行clear()方法

　　LinkedBlockingQueue執行clear方法時，會加上兩把鎖

?5、統計元素的個數

　　LinkedBlockingQueue中使用了一個AtomicInteger對象來統計元素的個數，ArrayBlockingQueue則使用int類型來統計元素。

?

這個博客寫的并發編程內容很全可以看看：http://tutorials.jenkov.com/java-concurrency/blocking-queues.html?

這個圖畫的很細，如果前面看不明白可以看看這個：深入剖析java并發之阻塞隊列LinkedBlockingQueue與ArrayBlockingQueue

?

總結

以上是生活随笔為你收集整理的有界阻塞队列ArrayBlockingQueue和无界阻塞队列LinkedBlockingQueue的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。