?ConcurrentLinkedQueue是一個基于鏈接節(jié)點的無界線程安全隊列，它采用先進先出的規(guī)則對節(jié)點進行排序，當我們添加一個元素的時候，它會添加到隊列的尾部；當我們獲取一個元素時，它會返回隊列頭部的元素。它采用了“wait-free”算法（即CAS算法）來實現(xiàn)。

阻塞隊列BlockingQueue：

支持阻塞的插入方法：意思是當隊列滿時，隊列會阻塞插入元素的線程，直到隊列不滿。

支持阻塞的移除方法：意思是在隊列為空時，獲取元素的線程會等待隊列變?yōu)榉强铡?/li>

Java里的阻塞隊列

ArrayBlockingQueue：一個由數(shù)組結(jié)構(gòu)組成的有界阻塞隊列,此隊列按照先進先出（FIFO）的原則對元素進行排序,不保證線程公平的訪問隊列;

LinkedBlockingQueue：一個由鏈表結(jié)構(gòu)組成的有界阻塞隊列，FIFO先進先出。

PriorityBlockingQueue：一個支持優(yōu)先級排序的無界阻塞隊列。

DelayQueue：是一個支持延時獲取元素的無界阻塞隊列。

SynchronousQueue：一個不存儲元素的阻塞隊列。

LinkedTransferQueue：一個由鏈表結(jié)構(gòu)組成的無界阻塞隊列。

LinkedBlockingDeque：一個由鏈表結(jié)構(gòu)組成的雙向阻塞隊列。

ArrayBlockingQueue 通過?ArrayBlockingQueue fairQueue = new ArrayBlockingQueue(1000,true);保證線程公平訪問隊列。

看下構(gòu)造方法：

public ArrayBlockingQueue(int capacity, boolean fair) {if (capacity <= 0)throw new IllegalArgumentException();this.items = new Object[capacity];lock = new ReentrantLock(fair);notEmpty = lock.newCondition();notFull = lock.newCondition();}

使用可重入鎖實現(xiàn)。

DelayQueue使用場景：

緩存系統(tǒng)設(shè)計；

定時任務(wù)調(diào)度；

?

SynchronousQueue是一個不存儲元素的阻塞隊列。每一個put操作必須等待一個take操作，否則不能繼續(xù)添加元素。
它支持公平訪問隊列。默認情況下線程采用非公平性策略訪問隊列。
SynchronousQueue的吞吐量高于LinkedBlockingQueue和ArrayBlockingQueue。

Fork Join框架：

Fork/Join框架是Java 7提供的一個用于并行執(zhí)行任務(wù)的框架，是一個把大任務(wù)分割成若干個小任務(wù)，最終匯總每個小任務(wù)結(jié)果后得到大任務(wù)結(jié)果的框架。

工作竊取算法：

優(yōu)點：充分利用線程并行計算，減少線程間競爭。

缺點：在某些情況下還是存在競爭，比如雙端隊列里只有一個任務(wù)時。并且該算法會消耗了更多的系統(tǒng)資源，比如創(chuàng)建多個線程和多個雙端隊列。

?

框架設(shè)計：

分割任務(wù)。首先我們需要有一個fork類來把大任務(wù)分割成子任務(wù)，有可能子任務(wù)還是很大，所以還需要不停地分割，直到分割出的子任務(wù)足夠小。

執(zhí)行任務(wù)并合并結(jié)果。分割的子任務(wù)分別放在雙端隊列里，然后幾個啟動線程分別從雙端隊列里獲取任務(wù)執(zhí)行。子任務(wù)執(zhí)行完的結(jié)果都統(tǒng)一放在一個隊列里，啟動一個線程從隊列里拿數(shù)據(jù)，然后合并這些數(shù)據(jù)。

?

總結(jié)

以上是生活随笔為你收集整理的java多线程 --ConcurrentLinkedQueue 非阻塞 线程安全队列的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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