更多 Java 并發(fā)編程方面的文章,請(qǐng)參見(jiàn)文集《Java 并發(fā)編程》
在 Java 多線程應(yīng)用中,隊(duì)列的使用率很高,多數(shù)生產(chǎn)消費(fèi)模型的首選數(shù)據(jù)結(jié)構(gòu)就是隊(duì)列(先進(jìn)先出)。
Java提供的線程安全的 Queue 可以分為
-
阻塞隊(duì)列,典型例子是
LinkedBlockingQueue- 適用阻塞隊(duì)列的好處:多線程操作共同的隊(duì)列時(shí)不需要額外的同步,另外就是隊(duì)列會(huì)自動(dòng)平衡負(fù)載,即那邊(生產(chǎn)與消費(fèi)兩邊)處理快了就會(huì)被阻塞掉,從而減少兩邊的處理速度差距。
-
非阻塞隊(duì)列,典型例子是
ConcurrentLinkedQueue- 當(dāng)許多線程共享訪問(wèn)一個(gè)公共集合時(shí),
ConcurrentLinkedQueue是一個(gè)恰當(dāng)?shù)倪x擇。
- 當(dāng)許多線程共享訪問(wèn)一個(gè)公共集合時(shí),
LinkedBlockingQueue 多用于任務(wù)隊(duì)列
ConcurrentLinkedQueue 多用于消息隊(duì)列
單生產(chǎn)者,單消費(fèi)者 用 LinkedBlockingqueue
多生產(chǎn)者,單消費(fèi)者 用 LinkedBlockingqueue
單生產(chǎn)者 ,多消費(fèi)者 用 ConcurrentLinkedQueue
多生產(chǎn)者 ,多消費(fèi)者 用 ConcurrentLinkedQueue
LinkedBlockingQueue
由于 LinkedBlockingQueue 實(shí)現(xiàn)是線程安全的,實(shí)現(xiàn)了先進(jìn)先出等特性,是作為生產(chǎn)者消費(fèi)者的首選,LinkedBlockingQueue 可以指定容量,也可以不指定,不指定的話,默認(rèn)最大是 Integer.MAX_VALUE。
-
void put(E e): 在隊(duì)尾插入元素,方法在隊(duì)列滿(mǎn)的時(shí)候會(huì)阻塞直到有隊(duì)列成員被消費(fèi) -
boolean offer(E e): 在隊(duì)尾插入元素,方法在隊(duì)列滿(mǎn)的時(shí)候不會(huì)阻塞,直接返回false -
E take(): 取出并刪除隊(duì)列中的首元素,如果隊(duì)列為空,會(huì)阻塞,直到有隊(duì)列成員被放進(jìn)來(lái) -
E poll(): 取出并刪除隊(duì)列中的首元素,如果隊(duì)列為空,則返回null,不進(jìn)行阻塞 -
E peek(): 取出第一個(gè)元素但是不刪除它,沒(méi)有就返回null
具體使用參見(jiàn) Java 通過(guò)阻塞隊(duì)列實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模式
ConcurrentLinkedQueue
ConcurrentLinkedQueue 是 Queue 的一個(gè)安全實(shí)現(xiàn)。Queue 中元素按 FIFO 原則進(jìn)行排序。采用 CAS操作,來(lái)保證元素的一致性。
-
boolean offer(E e): 在隊(duì)尾插入元素,不進(jìn)行阻塞 -
E poll(): 取出并刪除隊(duì)列中的首元素,不進(jìn)行阻塞 -
E peek(): 取出第一個(gè)元素但是不刪除它,不進(jìn)行阻塞
引用:
java挑戰(zhàn)高并發(fā)(14): LinkedBlockingQueue和ConcurrentLinkedQueue的區(qū)別及用法
并發(fā)隊(duì)列ConcurrentLinkedQueue和阻塞隊(duì)列LinkedBlockingQueue使用場(chǎng)景總結(jié)