轉(zhuǎn)載自https://blog.csdn.net/westos_linux/article/details/78968012

在Java多線程應(yīng)用中，隊(duì)列的使用率很高，多數(shù)生產(chǎn)消費(fèi)模型的首選數(shù)據(jù)結(jié)構(gòu)就是隊(duì)列(先進(jìn)先出)。Java提供的線程安全的Queue可以分為阻塞隊(duì)列和非阻塞隊(duì)列，其中阻塞隊(duì)列的典型例子是BlockingQueue，非阻塞隊(duì)列的典型例子是ConcurrentLinkedQueue，在實(shí)際應(yīng)用中要根據(jù)實(shí)際需要選用阻塞隊(duì)列或者非阻塞隊(duì)列。

注：什么叫線程安全？這個(gè)首先要明確。線程安全就是說(shuō)多線程訪問(wèn)同一代碼，不會(huì)產(chǎn)生不確定的結(jié)果。

并行和并發(fā)區(qū)別

1、并行是指兩者同時(shí)執(zhí)行一件事，比如賽跑，兩個(gè)人都在不停的往前跑；
2、并發(fā)是指資源有限的情況下，兩者交替輪流使用資源，比如一段路(單核CPU資源)同時(shí)只能過(guò)一個(gè)人，A走一段后，讓給B，B用完繼續(xù)給A ，交替使用，目的是提高效率

LinkedBlockingQueue
由于LinkedBlockingQueue實(shí)現(xiàn)是線程安全的，實(shí)現(xiàn)了先進(jìn)先出等特性，是作為生產(chǎn)者消費(fèi)者的首選，LinkedBlockingQueue 可以指定容量，也可以不指定，不指定的話，默認(rèn)最大是Integer.MAX_VALUE，其中主要用到put和take方法，put方法在隊(duì)列滿的時(shí)候會(huì)阻塞直到有隊(duì)列成員被消費(fèi)，take方法在隊(duì)列空的時(shí)候會(huì)阻塞，直到有隊(duì)列成員被放進(jìn)來(lái)。

package cn.thread;import java.util.concurrent.BlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingQueue;/*** 多線程模擬實(shí)現(xiàn)生產(chǎn)者／消費(fèi)者模型* * @author 林計(jì)欽* @version 1.0 2013-7-25 下午05:23:11*/ public class BlockingQueueTest2 {/*** * 定義裝蘋(píng)果的籃子* */public class Basket {// 籃子，能夠容納3個(gè)蘋(píng)果BlockingQueue<String> basket = new LinkedBlockingQueue<String>(3);// 生產(chǎn)蘋(píng)果，放入籃子public void produce() throws InterruptedException {// put方法放入一個(gè)蘋(píng)果，若basket滿了，等到basket有位置basket.put("An apple");}// 消費(fèi)蘋(píng)果，從籃子中取走public String consume() throws InterruptedException {// take方法取出一個(gè)蘋(píng)果，若basket為空，等到basket有蘋(píng)果為止(獲取并移除此隊(duì)列的頭部)return basket.take();}}// 定義蘋(píng)果生產(chǎn)者class Producer implements Runnable {private String instance;private Basket basket;public Producer(String instance, Basket basket) {this.instance = instance;this.basket = basket;}public void run() {try {while (true) {// 生產(chǎn)蘋(píng)果System.out.println("生產(chǎn)者準(zhǔn)備生產(chǎn)蘋(píng)果：" + instance);basket.produce();System.out.println("!生產(chǎn)者生產(chǎn)蘋(píng)果完畢：" + instance);// 休眠300msThread.sleep(300);}} catch (InterruptedException ex) {System.out.println("Producer Interrupted");}}}// 定義蘋(píng)果消費(fèi)者class Consumer implements Runnable {private String instance;private Basket basket;public Consumer(String instance, Basket basket) {this.instance = instance;this.basket = basket;}public void run() {try {while (true) {// 消費(fèi)蘋(píng)果System.out.println("消費(fèi)者準(zhǔn)備消費(fèi)蘋(píng)果：" + instance);System.out.println(basket.consume());System.out.println("!消費(fèi)者消費(fèi)蘋(píng)果完畢：" + instance);// 休眠1000msThread.sleep(1000);}} catch (InterruptedException ex) {System.out.println("Consumer Interrupted");}}}public static void main(String[] args) {BlockingQueueTest2 test = new BlockingQueueTest2();// 建立一個(gè)裝蘋(píng)果的籃子Basket basket = test.new Basket();ExecutorService service = Executors.newCachedThreadPool();Producer producer = test.new Producer("生產(chǎn)者001", basket);Producer producer2 = test.new Producer("生產(chǎn)者002", basket);Consumer consumer = test.new Consumer("消費(fèi)者001", basket);service.submit(producer);service.submit(producer2);service.submit(consumer);// 程序運(yùn)行5s后，所有任務(wù)停止 // try { // Thread.sleep(1000 * 5); // } catch (InterruptedException e) { // e.printStackTrace(); // } // service.shutdownNow();}}

ConcurrentLinkedQueue
ConcurrentLinkedQueue是Queue的一個(gè)安全實(shí)現(xiàn)．Queue中元素按FIFO原則進(jìn)行排序．采用CAS操作，來(lái)保證元素的一致性。
LinkedBlockingQueue是一個(gè)線程安全的阻塞隊(duì)列，它實(shí)現(xiàn)了BlockingQueue接口，BlockingQueue接口繼承自java.util.Queue接口，并在這個(gè)接口的基礎(chǔ)上增加了take和put方法，這兩個(gè)方法正是隊(duì)列操作的阻塞版本。

package cn.thread;import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class ConcurrentLinkedQueueTest {private static ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<Integer>();private static int count = 2; // 線程個(gè)數(shù)//CountDownLatch，一個(gè)同步輔助類(lèi)，在完成一組正在其他線程中執(zhí)行的操作之前，它允許一個(gè)或多個(gè)線程一直等待。private static CountDownLatch latch = new CountDownLatch(count);public static void main(String[] args) throws InterruptedException {long timeStart = System.currentTimeMillis();ExecutorService es = Executors.newFixedThreadPool(4);ConcurrentLinkedQueueTest.offer();for (int i = 0; i < count; i++) {es.submit(new Poll());}latch.await(); //使得主線程(main)阻塞直到latch.countDown()為零才繼續(xù)執(zhí)行System.out.println("cost time " + (System.currentTimeMillis() - timeStart) + "ms");es.shutdown();}/*** 生產(chǎn)*/public static void offer() {for (int i = 0; i < 100000; i++) {queue.offer(i);}}/*** 消費(fèi)* * @author 林計(jì)欽* @version 1.0 2013-7-25 下午05:32:56*/static class Poll implements Runnable {public void run() {// while (queue.size()>0) {while (!queue.isEmpty()) {System.out.println(queue.poll());}latch.countDown();}} }

運(yùn)行結(jié)果：
costtime 2360ms

改用while (queue.size()>0)后
運(yùn)行結(jié)果：
cost time 46422ms

結(jié)果居然相差那么大，看了下ConcurrentLinkedQueue的API原來(lái).size()是要遍歷一遍集合的，難怪那么慢，所以盡量要避免用size而改用isEmpty().

總結(jié)了下， 在單位缺乏性能測(cè)試下，對(duì)自己的編程要求更加要嚴(yán)格，特別是在生產(chǎn)環(huán)境下更是要小心謹(jǐn)慎。

總結(jié)

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

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