https://blog.csdn.net/defonds/article/details/44021605/

譯序

1. java.util.concurrent - Java 并發(fā)工具包

Java 5 添加了一個(gè)新的包到 Java 平臺(tái)绘闷，java.util.concurrent 包蜕劝。這個(gè)包包含有一系列能夠讓 Java 的并發(fā)編程變得更加簡(jiǎn)單輕松的類酪惭。在這個(gè)包被添加以前液南，你需要自己去動(dòng)手實(shí)現(xiàn)自己的相關(guān)工具類鹃唯。
本文我將帶你一一認(rèn)識(shí) java.util.concurrent 包里的這些類榆芦，然后你可以嘗試著如何在項(xiàng)目中使用它們达椰。本文中我將使用 Java 6 版本友绝，我不確定這和 Java 5 版本里的是否有一些差異抛腕。
我不會(huì)去解釋關(guān)于 Java 并發(fā)的核心問(wèn)題 - 其背后的原理芋绸，也就是說(shuō)，如果你對(duì)那些東西感興趣担敌，參考《Java 并發(fā)指南》摔敛。

半成品

2. 阻塞隊(duì)列 BlockingQueue

java.util.concurrent 包里的 BlockingQueue 接口表示一個(gè)線程安放入和提取實(shí)例的隊(duì)列。本小節(jié)我將給你演示如何使用這個(gè) BlockingQueue全封。
本節(jié)不會(huì)討論如何在 Java 中實(shí)現(xiàn)一個(gè)你自己的 BlockingQueue马昙。如果你對(duì)那個(gè)感興趣桃犬，參考《Java 并發(fā)指南》

BlockingQueue 用法

BlockingQueue 通常用于一個(gè)線程生產(chǎn)對(duì)象，而另外一個(gè)線程消費(fèi)這些對(duì)象的場(chǎng)景行楞。下圖是對(duì)這個(gè)原理的闡述：

blocking-queue

一個(gè)線程往里邊放攒暇，另外一個(gè)線程從里邊取的一個(gè) BlockingQueue。
一個(gè)線程將會(huì)持續(xù)生產(chǎn)新對(duì)象并將其插入到隊(duì)列之中子房，直到隊(duì)列達(dá)到它所能容納的臨界點(diǎn)形用。也就是說(shuō)，它是有限的证杭。如果該阻塞隊(duì)列到達(dá)了其臨界點(diǎn)田度，負(fù)責(zé)生產(chǎn)的線程將會(huì)在往里邊插入新對(duì)象時(shí)發(fā)生阻塞。它會(huì)一直處于阻塞之中解愤，直到負(fù)責(zé)消費(fèi)的線程從隊(duì)列中拿走一個(gè)對(duì)象。
負(fù)責(zé)消費(fèi)的線程將會(huì)一直從該阻塞隊(duì)列中拿出對(duì)象琢歇。如果消費(fèi)線程嘗試去從一個(gè)空的隊(duì)列中提取對(duì)象的話兰怠，這個(gè)消費(fèi)線程將會(huì)處于阻塞之中，直到一個(gè)生產(chǎn)線程把一個(gè)對(duì)象丟進(jìn)隊(duì)列李茫。

BlockingQueue 的方法

BlockingQueue 具有 4 組不同的方法用于插入揭保、移除以及對(duì)隊(duì)列中的元素進(jìn)行檢查。如果請(qǐng)求的操作不能得到立即執(zhí)行的話魄宏，每個(gè)方法的表現(xiàn)也不同秸侣。這些方法如下：

| | | | | |
| | | | | |
| | | | | |
| | | | | |

四組不同的行為方式解釋：

1. 拋異常：如果試圖的操作無(wú)法立即執(zhí)行，拋一個(gè)異常宠互。
2. 特定值：如果試圖的操作無(wú)法立即執(zhí)行味榛，返回一個(gè)特定的值(常常是 true / false)。
3. 阻塞：如果試圖的操作無(wú)法立即執(zhí)行予跌，該方法調(diào)用將會(huì)發(fā)生阻塞搏色，直到能夠執(zhí)行。
4. 超時(shí)：如果試圖的操作無(wú)法立即執(zhí)行券册，該方法調(diào)用將會(huì)發(fā)生阻塞频轿，直到能夠執(zhí)行，但等待時(shí)間不會(huì)超過(guò)給定值烁焙。返回一個(gè)特定值以告知該操作是否成功(典型的是 true / false)航邢。

無(wú)法向一個(gè) BlockingQueue 中插入 null。如果你試圖插入 null骄蝇，BlockingQueue 將會(huì)拋出一個(gè) NullPointerException膳殷。
可以訪問(wèn)到 BlockingQueue 中的所有元素，而不僅僅是開始和結(jié)束的元素九火。比如說(shuō)赚窃，你將一個(gè)對(duì)象放入隊(duì)列之中以等待處理册招，但你的應(yīng)用想要將其取消掉。那么你可以調(diào)用諸如 remove(o) 方法來(lái)將隊(duì)列之中的特定對(duì)象進(jìn)行移除考榨。但是這么干效率并不高(譯者注：基于隊(duì)列的數(shù)據(jù)結(jié)構(gòu)跨细，獲取除開始或結(jié)束位置的其他對(duì)象的效率不會(huì)太高)，因此你盡量不要用這一類的方法河质，除非你確實(shí)不得不那么做。

BlockingQueue 的實(shí)現(xiàn)

BlockingQueue 是個(gè)接口震叙，你需要使用它的實(shí)現(xiàn)之一來(lái)使用 BlockingQueue掀鹅。java.util.concurrent 具有以下 BlockingQueue 接口的實(shí)現(xiàn)(Java 6)：

• ArrayBlockingQueue
• DelayQueue
• LinkedBlockingQueue
• PriorityBlockingQueue
• SynchronousQueue

Java 中使用 BlockingQueue 的例子

這里是一個(gè) Java 中使用 BlockingQueue 的示例。本示例使用的是 BlockingQueue 接口的 ArrayBlockingQueue 實(shí)現(xiàn)媒楼。
首先乐尊，BlockingQueueExample 類分別在兩個(gè)獨(dú)立的線程中啟動(dòng)了一個(gè) Producer 和 一個(gè) Consumer。Producer 向一個(gè)共享的 BlockingQueue 中注入字符串划址，而 Consumer 則會(huì)從中把它們拿出來(lái)扔嵌。

以下是 Producer 類。注意它在每次 put() 調(diào)用時(shí)是如何休眠一秒鐘的夺颤。這將導(dǎo)致 Consumer 在等待隊(duì)列中對(duì)象的時(shí)候發(fā)生阻塞痢缎。

以下是 Consumer 類。它只是把對(duì)象從隊(duì)列中抽取出來(lái)世澜，然后將它們打印到 System.out独旷。

3. 數(shù)組阻塞隊(duì)列 ArrayBlockingQueue

ArrayBlockingQueue 類實(shí)現(xiàn)了 BlockingQueue 接口。
ArrayBlockingQueue 是一個(gè)有界的阻塞隊(duì)列寥裂，其內(nèi)部實(shí)現(xiàn)是將對(duì)象放到一個(gè)數(shù)組里嵌洼。有界也就意味著，它不能夠存儲(chǔ)無(wú)限多數(shù)量的元素封恰。它有一個(gè)同一時(shí)間能夠存儲(chǔ)元素?cái)?shù)量的上限麻养。你可以在對(duì)其初始化的時(shí)候設(shè)定這個(gè)上限，但之后就無(wú)法對(duì)這個(gè)上限進(jìn)行修改了(譯者注：因?yàn)樗腔跀?shù)組實(shí)現(xiàn)的诺舔，也就具有數(shù)組的特性：一旦初始化鳖昌，大小就無(wú)法修改)。
ArrayBlockingQueue 內(nèi)部以 FIFO(先進(jìn)先出)的順序?qū)υ剡M(jìn)行存儲(chǔ)混萝。隊(duì)列中的頭元素在所有元素之中是放入時(shí)間最久的那個(gè)遗遵，而尾元素則是最短的那個(gè)。
以下是在使用 ArrayBlockingQueue 的時(shí)候?qū)ζ涑跏蓟囊粋€(gè)示例：

以下是使用了 Java 泛型的一個(gè) BlockingQueue 示例逸嘀。注意其中是如何對(duì) String 元素放入和提取的：

4. 延遲隊(duì)列 DelayQueue

DelayQueue 實(shí)現(xiàn)了 BlockingQueue 接口车要。
DelayQueue 對(duì)元素進(jìn)行持有直到一個(gè)特定的延遲到期。注入其中的元素必須實(shí)現(xiàn) java.util.concurrent.Delayed 接口崭倘，該接口定義：

DelayQueue 將會(huì)在每個(gè)元素的 getDelay() 方法返回的值的時(shí)間段之后才釋放掉該元素翼岁。如果返回的是 0 或者負(fù)值类垫，延遲將被認(rèn)為過(guò)期，該元素將會(huì)在 DelayQueue 的下一次 take 被調(diào)用的時(shí)候被釋放掉琅坡。
傳遞給 getDelay 方法的 getDelay 實(shí)例是一個(gè)枚舉類型悉患，它表明了將要延遲的時(shí)間段。TimeUnit 枚舉將會(huì)取以下值：

正如你所看到的榆俺，Delayed 接口也繼承了 java.lang.Comparable 接口售躁，這也就意味著 Delayed 對(duì)象之間可以進(jìn)行對(duì)比。這個(gè)可能在對(duì) DelayQueue 隊(duì)列中的元素進(jìn)行排序時(shí)有用茴晋，因此它們可以根據(jù)過(guò)期時(shí)間進(jìn)行有序釋放陪捷。
以下是使用 DelayQueue 的例子：

5. 鏈阻塞隊(duì)列 LinkedBlockingQueue

LinkedBlockingQueue 類實(shí)現(xiàn)了 BlockingQueue 接口。
LinkedBlockingQueue 內(nèi)部以一個(gè)鏈?zhǔn)浇Y(jié)構(gòu)(鏈接節(jié)點(diǎn))對(duì)其元素進(jìn)行存儲(chǔ)诺擅。如果需要的話市袖，這一鏈?zhǔn)浇Y(jié)構(gòu)可以選擇一個(gè)上限。如果沒(méi)有定義上限烁涌，將使用 Integer.MAX_VALUE 作為上限苍碟。
LinkedBlockingQueue 內(nèi)部以 FIFO(先進(jìn)先出)的順序?qū)υ剡M(jìn)行存儲(chǔ)。隊(duì)列中的頭元素在所有元素之中是放入時(shí)間最久的那個(gè)撮执，而尾元素則是最短的那個(gè)微峰。
以下是 LinkedBlockingQueue 的初始化和使用示例代碼：

6. 具有優(yōu)先級(jí)的阻塞隊(duì)列 PriorityBlockingQueue

PriorityBlockingQueue 類實(shí)現(xiàn)了 BlockingQueue 接口。
PriorityBlockingQueue 是一個(gè)無(wú)界的并發(fā)隊(duì)列二打。它使用了和類 java.util.PriorityQueue 一樣的排序規(guī)則县忌。你無(wú)法向這個(gè)隊(duì)列中插入 null 值。
所有插入到 PriorityBlockingQueue 的元素必須實(shí)現(xiàn) java.lang.Comparable 接口继效。因此該隊(duì)列中元素的排序就取決于你自己的 Comparable 實(shí)現(xiàn)症杏。
注意 PriorityBlockingQueue 對(duì)于具有相等優(yōu)先級(jí)(compare() == 0)的元素并不強(qiáng)制任何特定行為。
同時(shí)注意瑞信，如果你從一個(gè) PriorityBlockingQueue 獲得一個(gè) Iterator 的話厉颤，該 Iterator 并不能保證它對(duì)元素的遍歷是以優(yōu)先級(jí)為序的。
以下是使用 PriorityBlockingQueue 的示例：

7. 同步隊(duì)列 SynchronousQueue

SynchronousQueue 類實(shí)現(xiàn)了 BlockingQueue 接口凡简。
SynchronousQueue 是一個(gè)特殊的隊(duì)列逼友，它的內(nèi)部同時(shí)只能夠容納單個(gè)元素。如果該隊(duì)列已有一元素的話秤涩，試圖向隊(duì)列中插入一個(gè)新元素的線程將會(huì)阻塞帜乞，直到另一個(gè)線程將該元素從隊(duì)列中抽走。同樣筐眷，如果該隊(duì)列為空黎烈，試圖向隊(duì)列中抽取一個(gè)元素的線程將會(huì)阻塞，直到另一個(gè)線程向隊(duì)列中插入了一條新的元素。

8. 阻塞雙端隊(duì)列 BlockingDeque

java.util.concurrent 包里的 BlockingDeque 接口表示一個(gè)線程安放入和提取實(shí)例的雙端隊(duì)列照棋。本小節(jié)我將給你演示如何使用 BlockingDeque资溃。
BlockingDeque 類是一個(gè)雙端隊(duì)列，在不能夠插入元素時(shí)烈炭，它將阻塞住試圖插入元素的線程溶锭；在不能夠抽取元素時(shí)，它將阻塞住試圖抽取的線程符隙。
deque(雙端隊(duì)列) 是 "Double Ended Queue" 的縮寫趴捅。因此，雙端隊(duì)列是一個(gè)你可以從任意一端插入或者抽取元素的隊(duì)列霹疫。

BlockingDeque 的使用

在線程既是一個(gè)隊(duì)列的生產(chǎn)者又是這個(gè)隊(duì)列的消費(fèi)者的時(shí)候可以使用到 BlockingDeque驻售。如果生產(chǎn)者線程需要在隊(duì)列的兩端都可以插入數(shù)據(jù)，消費(fèi)者線程需要在隊(duì)列的兩端都可以移除數(shù)據(jù)更米，這個(gè)時(shí)候也可以使用 BlockingDeque。BlockingDeque 圖解：

blocking-deque

一個(gè) BlockingDeque - 線程在雙端隊(duì)列的兩端都可以插入和提取元素毫痕。
一個(gè)線程生產(chǎn)元素征峦，并把它們插入到隊(duì)列的任意一端。如果雙端隊(duì)列已滿消请，插入線程將被阻塞栏笆，直到一個(gè)移除線程從該隊(duì)列中移出了一個(gè)元素。如果雙端隊(duì)列為空臊泰，移除線程將被阻塞蛉加，直到一個(gè)插入線程向該隊(duì)列插入了一個(gè)新元素。

BlockingDeque 的方法

BlockingDeque 具有 4 組不同的方法用于插入缸逃、移除以及對(duì)雙端隊(duì)列中的元素進(jìn)行檢查针饥。如果請(qǐng)求的操作不能得到立即執(zhí)行的話，每個(gè)方法的表現(xiàn)也不同丁眼。這些方法如下：

| | | | | |
| | | | | |
| | | | | |
| | | | | |

| | | | | |
| | | | | |
| | | | | |
| | | | | |

四組不同的行為方式解釋：

1. 拋異常：如果試圖的操作無(wú)法立即執(zhí)行，拋一個(gè)異常昭殉。
2. 特定值：如果試圖的操作無(wú)法立即執(zhí)行苞七，返回一個(gè)特定的值(常常是 true / false)。
3. 阻塞：如果試圖的操作無(wú)法立即執(zhí)行挪丢，該方法調(diào)用將會(huì)發(fā)生阻塞蹂风，直到能夠執(zhí)行。
4. 超時(shí)：如果試圖的操作無(wú)法立即執(zhí)行乾蓬，該方法調(diào)用將會(huì)發(fā)生阻塞惠啄，直到能夠執(zhí)行，但等待時(shí)間不會(huì)超過(guò)給定值。返回一個(gè)特定值以告知該操作是否成功(典型的是 true / false)礁阁。

BlockingDeque 繼承自 BlockingQueue

BlockingDeque 接口繼承自 BlockingQueue 接口巧号。這就意味著你可以像使用一個(gè) BlockingQueue 那樣使用 BlockingDeque。如果你這么干的話姥闭，各種插入方法將會(huì)把新元素添加到雙端隊(duì)列的尾端丹鸿，而移除方法將會(huì)把雙端隊(duì)列的首端的元素移除。正如 BlockingQueue 接口的插入和移除方法一樣棚品。
以下是 BlockingDeque 對(duì) BlockingQueue 接口的方法的具體內(nèi)部實(shí)現(xiàn)：

| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |

BlockingDeque 的實(shí)現(xiàn)

既然 BlockingDeque 是一個(gè)接口靠欢，那么你想要使用它的話就得使用它的眾多的實(shí)現(xiàn)類的其中一個(gè)。java.util.concurrent 包提供了以下 BlockingDeque 接口的實(shí)現(xiàn)類：

• LinkedBlockingDeque

BlockingDeque 代碼示例

以下是如何使用 BlockingDeque 方法的一個(gè)簡(jiǎn)短代碼示例：

9. 鏈阻塞雙端隊(duì)列 LinkedBlockingDeque

LinkedBlockingDeque 類實(shí)現(xiàn)了 BlockingDeque 接口铜跑。
deque(雙端隊(duì)列) 是 "Double Ended Queue" 的縮寫门怪。因此，雙端隊(duì)列是一個(gè)你可以從任意一端插入或者抽取元素的隊(duì)列锅纺。(譯者注：唐僧啊掷空，受不了。)
LinkedBlockingDeque 是一個(gè)雙端隊(duì)列囤锉，在它為空的時(shí)候坦弟，一個(gè)試圖從中抽取數(shù)據(jù)的線程將會(huì)阻塞，無(wú)論該線程是試圖從哪一端抽取數(shù)據(jù)官地。
以下是 LinkedBlockingDeque 實(shí)例化以及使用的示例：

10. 并發(fā) Map(映射) ConcurrentMap

java.util.concurrent.ConcurrentMap

java.util.concurrent.ConcurrentMap 接口表示了一個(gè)能夠?qū)e人的訪問(wèn)(插入和提取)進(jìn)行并發(fā)處理的 java.util.Map酿傍。
ConcurrentMap 除了從其父接口 java.util.Map 繼承來(lái)的方法之外還有一些額外的原子性方法。

ConcurrentMap 的實(shí)現(xiàn)

既然 ConcurrentMap 是個(gè)接口驱入，你想要使用它的話就得使用它的實(shí)現(xiàn)類之一赤炒。java.util.concurrent 包具備 ConcurrentMap 接口的以下實(shí)現(xiàn)類：

• ConcurrentHashMap

ConcurrentHashMap

ConcurrentHashMap 和 java.util.HashTable 類很相似，但 ConcurrentHashMap 能夠提供比 HashTable 更好的并發(fā)性能亏较。在你從中讀取對(duì)象的時(shí)候 ConcurrentHashMap 并不會(huì)把整個(gè) Map 鎖住莺褒。此外，在你向其中寫入對(duì)象的時(shí)候宴杀，ConcurrentHashMap 也不會(huì)鎖住整個(gè) Map癣朗。它的內(nèi)部只是把 Map 中正在被寫入的部分進(jìn)行鎖定。
另外一個(gè)不同點(diǎn)是旺罢，在被遍歷的時(shí)候旷余，即使是 ConcurrentHashMap 被改動(dòng)，它也不會(huì)拋 ConcurrentModificationException扁达。盡管 Iterator 的設(shè)計(jì)不是為多個(gè)線程的同時(shí)使用正卧。
更多關(guān)于 ConcurrentMap 和 ConcurrentHashMap 的細(xì)節(jié)請(qǐng)參考官方文檔。

ConcurrentMap 例子

以下是如何使用 ConcurrentMap 接口的一個(gè)例子跪解。本示例使用了 ConcurrentHashMap 實(shí)現(xiàn)類：

11. 并發(fā)導(dǎo)航映射 ConcurrentNavigableMap

java.util.concurrent.ConcurrentNavigableMap 是一個(gè)支持并發(fā)訪問(wèn)的 java.util.NavigableMap炉旷，它還能讓它的子 map 具備并發(fā)訪問(wèn)的能力。所謂的 "子 map" 指的是諸如 headMap()，subMap()窘行，tailMap() 之類的方法返回的 map饥追。

headMap()

headMap(T toKey) 方法返回一個(gè)包含了小于給定 toKey 的 key 的子 map。
如果你對(duì)原始 map 里的元素做了改動(dòng)罐盔，這些改動(dòng)將影響到子 map 中的元素(譯者注：map 集合持有的其實(shí)只是對(duì)象的引用)但绕。
以下示例演示了對(duì) headMap() 方法的使用：

headMap 將指向一個(gè)只含有鍵 "1" 的 ConcurrentNavigableMap，因?yàn)橹挥羞@一個(gè)鍵小于 "2"惶看。關(guān)于這個(gè)方法及其重載版本具體是怎么工作的細(xì)節(jié)請(qǐng)參考 Java 文檔捏顺。

tailMap()

tailMap(T fromKey) 方法返回一個(gè)包含了不小于給定 fromKey 的 key 的子 map。
如果你對(duì)原始 map 里的元素做了改動(dòng)纬黎，這些改動(dòng)將影響到子 map 中的元素(譯者注：map 集合持有的其實(shí)只是對(duì)象的引用)幅骄。
以下示例演示了對(duì) tailMap() 方法的使用：

tailMap 將擁有鍵 "2" 和 "3"，因?yàn)樗鼈儾恍∮诮o定鍵 "2"本今。關(guān)于這個(gè)方法及其重載版本具體是怎么工作的細(xì)節(jié)請(qǐng)參考 Java 文檔。

subMap()

subMap() 方法返回原始 map 中冠息，鍵介于 from(包含) 和 to (不包含) 之間的子 map铐达。示例如下：

返回的 submap 只包含鍵 "2"沿猜，因?yàn)橹挥兴鼭M足不小于 "2"祈坠，比 "3" 小害碾。

更多方法

ConcurrentNavigableMap 接口還有其他一些方法可供使用，比如：

• descendingKeySet()
• descendingMap()
• navigableKeySet()

12. 閉鎖 CountDownLatch

java.util.concurrent.CountDownLatch 是一個(gè)并發(fā)構(gòu)造赦拘，它允許一個(gè)或多個(gè)線程等待一系列指定操作的完成慌随。
CountDownLatch 以一個(gè)給定的數(shù)量初始化。countDown() 每被調(diào)用一次另绩，這一數(shù)量就減一儒陨。通過(guò)調(diào)用 await() 方法之一，線程可以阻塞等待這一數(shù)量到達(dá)零笋籽。
以下是一個(gè)簡(jiǎn)單示例蹦漠。Decrementer 三次調(diào)用 countDown() 之后，等待中的 Waiter 才會(huì)從 await() 調(diào)用中釋放出來(lái)车海。

13. 柵欄 CyclicBarrier

java.util.concurrent.CyclicBarrier 類是一種同步機(jī)制笛园，它能夠?qū)μ幚硪恍┧惴ǖ木€程實(shí)現(xiàn)同步。換句話講侍芝，它就是一個(gè)所有線程必須等待的一個(gè)柵欄研铆，直到所有線程都到達(dá)這里，然后所有線程才可以繼續(xù)做其他事情。圖示如下：

cyclic-barrier

兩個(gè)線程在柵欄旁等待對(duì)方榨惰。
通過(guò)調(diào)用 CyclicBarrier 對(duì)象的 await() 方法祟昭，兩個(gè)線程可以實(shí)現(xiàn)互相等待。一旦 N 個(gè)線程在等待 CyclicBarrier 達(dá)成逆甜，所有線程將被釋放掉去繼續(xù)運(yùn)行。

創(chuàng)建一個(gè) CyclicBarrier

在創(chuàng)建一個(gè) CyclicBarrier 的時(shí)候你需要定義有多少線程在被釋放之前等待柵欄致板。創(chuàng)建 CyclicBarrier 示例：

等待一個(gè) CyclicBarrier

以下演示了如何讓一個(gè)線程等待一個(gè) CyclicBarrier：

當(dāng)然交煞，你也可以為等待線程設(shè)定一個(gè)超時(shí)時(shí)間。等待超過(guò)了超時(shí)時(shí)間之后斟或，即便還沒(méi)有達(dá)成 N 個(gè)線程等待 CyclicBarrier 的條件素征，該線程也會(huì)被釋放出來(lái)。以下是定義超時(shí)時(shí)間示例：

滿足以下任何條件都可以讓等待 CyclicBarrier 的線程釋放：

• 最后一個(gè)線程也到達(dá) CyclicBarrier(調(diào)用 await())
• 當(dāng)前線程被其他線程打斷(其他線程調(diào)用了這個(gè)線程的 interrupt() 方法)
• 其他等待柵欄的線程被打斷
• 其他等待柵欄的線程因超時(shí)而被釋放
• 外部線程調(diào)用了柵欄的 CyclicBarrier.reset() 方法

CyclicBarrier 行動(dòng)

CyclicBarrier 支持一個(gè)柵欄行動(dòng)萝挤，柵欄行動(dòng)是一個(gè) Runnable 實(shí)例御毅，一旦最后等待柵欄的線程抵達(dá)，該實(shí)例將被執(zhí)行怜珍。你可以在 CyclicBarrier 的構(gòu)造方法中將 Runnable 柵欄行動(dòng)傳給它：

CyclicBarrier 示例

以下代碼演示了如何使用 CyclicBarrier：

CyclicBarrierRunnable 類：

以上代碼控制臺(tái)輸出如下亚享。注意每個(gè)線程寫入控制臺(tái)的時(shí)序可能會(huì)跟你實(shí)際執(zhí)行不一樣。比如有時(shí) Thread-0 先打印绘面，有時(shí) Thread-1 先打印欺税。
Thread-0 waiting at barrier 1
Thread-1 waiting at barrier 1
BarrierAction 1 executed
Thread-1 waiting at barrier 2
Thread-0 waiting at barrier 2
BarrierAction 2 executed
Thread-0 done!

14. 交換機(jī) Exchanger

java.util.concurrent.Exchanger 類表示一種兩個(gè)線程可以進(jìn)行互相交換對(duì)象的會(huì)和點(diǎn)侈沪。這種機(jī)制圖示如下：

exchanger

兩個(gè)線程通過(guò)一個(gè) Exchanger 交換對(duì)象。
交換對(duì)象的動(dòng)作由 Exchanger 的兩個(gè) exchange() 方法的其中一個(gè)完成晚凿。以下是一個(gè)示例：
ExchangerRunnable 代碼：

以上程序輸出：
Thread-0 exchanged A for B

15. 信號(hào)量 Semaphore

java.util.concurrent.Semaphore 類是一個(gè)計(jì)數(shù)信號(hào)量亭罪。這就意味著它具備兩個(gè)主要方法：

• acquire()
• release()

計(jì)數(shù)信號(hào)量由一個(gè)指定數(shù)量的 "許可" 初始化。每調(diào)用一次 acquire()歼秽，一個(gè)許可會(huì)被調(diào)用線程取走应役。每調(diào)用一次 release()，一個(gè)許可會(huì)被返還給信號(hào)量燥筷。因此箩祥，在沒(méi)有任何 release() 調(diào)用時(shí)，最多有 N 個(gè)線程能夠通過(guò) acquire() 方法肆氓，N 是該信號(hào)量初始化時(shí)的許可的指定數(shù)量袍祖。這些許可只是一個(gè)簡(jiǎn)單的計(jì)數(shù)器。這里沒(méi)啥奇特的地方谢揪。

Semaphore 用法

信號(hào)量主要有兩種用途：

1. 保護(hù)一個(gè)重要(代碼)部分防止一次超過(guò) N 個(gè)線程進(jìn)入蕉陋。
2. 在兩個(gè)線程之間發(fā)送信號(hào)。

保護(hù)重要部分

在線程之間發(fā)送信號(hào)

如果你將一個(gè)信號(hào)量用于在兩個(gè)線程之間傳送信號(hào)拨扶，通常你應(yīng)該用一個(gè)線程調(diào)用 acquire() 方法凳鬓，而另一個(gè)線程調(diào)用 release() 方法。
如果沒(méi)有可用的許可患民，acquire() 調(diào)用將會(huì)阻塞缩举，直到一個(gè)許可被另一個(gè)線程釋放出來(lái)。同理匹颤，如果無(wú)法往信號(hào)量釋放更多許可時(shí)蚁孔，一個(gè) release() 調(diào)用也會(huì)阻塞。
通過(guò)這個(gè)可以對(duì)多個(gè)線程進(jìn)行協(xié)調(diào)惋嚎。比如，如果線程 1 將一個(gè)對(duì)象插入到了一個(gè)共享列表(list)之后之后調(diào)用了 acquire()站刑，而線程 2 則在從該列表中獲取一個(gè)對(duì)象之前調(diào)用了 release()另伍，這時(shí)你其實(shí)已經(jīng)創(chuàng)建了一個(gè)阻塞隊(duì)列。信號(hào)量中可用的許可的數(shù)量也就等同于該阻塞隊(duì)列能夠持有的元素個(gè)數(shù)绞旅。

公平

沒(méi)有辦法保證線程能夠公平地可從信號(hào)量中獲得許可摆尝。也就是說(shuō)，無(wú)法擔(dān)保掉第一個(gè)調(diào)用 acquire() 的線程會(huì)是第一個(gè)獲得一個(gè)許可的線程因悲。如果第一個(gè)線程在等待一個(gè)許可時(shí)發(fā)生阻塞堕汞，而第二個(gè)線程前來(lái)索要一個(gè)許可的時(shí)候剛好有一個(gè)許可被釋放出來(lái)，那么它就可能會(huì)在第一個(gè)線程之前獲得許可晃琳。
如果你想要強(qiáng)制公平讯检，Semaphore 類有一個(gè)具有一個(gè)布爾類型的參數(shù)的構(gòu)造子琐鲁，通過(guò)這個(gè)參數(shù)以告知 Semaphore 是否要強(qiáng)制公平。強(qiáng)制公平會(huì)影響到并發(fā)性能人灼，所以除非你確實(shí)需要它否則不要啟用它围段。
以下是如何在公平模式創(chuàng)建一個(gè) Semaphore 的示例：

更多方法

java.util.concurrent.Semaphore 類還有很多方法，比如：

• availablePermits()
• acquireUninterruptibly()
• drainPermits()
• hasQueuedThreads()
• getQueuedThreads()
• tryAcquire()
• 等等

16. 執(zhí)行器服務(wù) ExecutorService

java.util.concurrent.ExecutorService 接口表示一個(gè)異步執(zhí)行機(jī)制投放，使我們能夠在后臺(tái)執(zhí)行任務(wù)奈泪。因此一個(gè) ExecutorService 很類似于一個(gè)線程池。實(shí)際上灸芳，存在于 java.util.concurrent 包里的 ExecutorService 實(shí)現(xiàn)就是一個(gè)線程池實(shí)現(xiàn)涝桅。

ExecutorService 例子

以下是一個(gè)簡(jiǎn)單的 ExecutorService 例子：

首先使用 newFixedThreadPool() 工廠方法創(chuàng)建一個(gè) ExecutorService。這里創(chuàng)建了一個(gè)十個(gè)線程執(zhí)行任務(wù)的線程池烙样。
然后冯遂，將一個(gè) Runnable 接口的匿名實(shí)現(xiàn)類傳遞給 execute() 方法。這將導(dǎo)致 ExecutorService 中的某個(gè)線程執(zhí)行該 Runnable误阻。

任務(wù)委派

下圖說(shuō)明了一個(gè)線程是如何將一個(gè)任務(wù)委托給一個(gè) ExecutorService 去異步執(zhí)行的：

executor-service

一個(gè)線程將一個(gè)任務(wù)委派給一個(gè) ExecutorService 去異步執(zhí)行债蜜。
一旦該線程將任務(wù)委派給 ExecutorService，該線程將繼續(xù)它自己的執(zhí)行究反，獨(dú)立于該任務(wù)的執(zhí)行寻定。

ExecutorService 實(shí)現(xiàn)

既然 ExecutorService 是個(gè)接口，如果你想用它的話就得去使用它的實(shí)現(xiàn)類之一精耐。java.util.concurrent 包提供了 ExecutorService 接口的以下實(shí)現(xiàn)類：

• ThreadPoolExecutor
• ScheduledThreadPoolExecutor

創(chuàng)建一個(gè) ExecutorService

ExecutorService 的創(chuàng)建依賴于你使用的具體實(shí)現(xiàn)狼速。但是你也可以使用 Executors 工廠類來(lái)創(chuàng)建 ExecutorService 實(shí)例。以下是幾個(gè)創(chuàng)建 ExecutorService 實(shí)例的例子：

ExecutorService 使用

有幾種不同的方式來(lái)將任務(wù)委托給 ExecutorService 去執(zhí)行：

• execute(Runnable)
• submit(Runnable)
• submit(Callable)
• invokeAny(...)
• invokeAll(...)

接下來(lái)我們挨個(gè)看一下這些方法卦停。

execute(Runnable)

execute(Runnable) 方法要求一個(gè) java.lang.Runnable 對(duì)象向胡，然后對(duì)它進(jìn)行異步執(zhí)行。以下是使用 ExecutorService 執(zhí)行一個(gè) Runnable 的示例：

沒(méi)有辦法得知被執(zhí)行的 Runnable 的執(zhí)行結(jié)果惊完。如果有需要的話你得使用一個(gè) Callable(以下將做介紹)僵芹。

submit(Runnable)

submit(Runnable) 方法也要求一個(gè) Runnable 實(shí)現(xiàn)類，但它返回一個(gè) Future 對(duì)象小槐。這個(gè) Future 對(duì)象可以用來(lái)檢查 Runnable 是否已經(jīng)執(zhí)行完畢拇派。
以下是 ExecutorService submit() 示例：

submit(Callable)

submit(Callable) 方法類似于 submit(Runnable) 方法，除了它所要求的參數(shù)類型之外凿跳。Callable 實(shí)例除了它的 call() 方法能夠返回一個(gè)結(jié)果之外和一個(gè) Runnable 很相像件豌。Runnable.run() 不能夠返回一個(gè)結(jié)果。
Callable 的結(jié)果可以通過(guò) submit(Callable) 方法返回的 Future 對(duì)象進(jìn)行獲取控嗜。以下是一個(gè) ExecutorService Callable 示例：

以上代碼輸出：
Asynchronous Callable
future.get() = Callable Result

invokeAny()

invokeAny() 方法要求一系列的 Callable 或者其子接口的實(shí)例對(duì)象茧彤。調(diào)用這個(gè)方法并不會(huì)返回一個(gè) Future，但它返回其中一個(gè) Callable 對(duì)象的結(jié)果疆栏。無(wú)法保證返回的是哪個(gè) Callable 的結(jié)果 - 只能表明其中一個(gè)已執(zhí)行結(jié)束曾掂。
如果其中一個(gè)任務(wù)執(zhí)行結(jié)束(或者拋了一個(gè)異常)惫谤，其他 Callable 將被取消。
以下是示例代碼：

上述代碼將會(huì)打印出給定 Callable 集合中的一個(gè)的執(zhí)行結(jié)果遭殉。我自己試著執(zhí)行了它幾次石挂，結(jié)果始終在變。有時(shí)是 "Task 1"险污，有時(shí)是 "Task 2" 等等痹愚。

invokeAll()

invokeAll() 方法將調(diào)用你在集合中傳給 ExecutorService 的所有 Callable 對(duì)象。invokeAll() 返回一系列的 Future 對(duì)象蛔糯，通過(guò)它們你可以獲取每個(gè) Callable 的執(zhí)行結(jié)果拯腮。
記住，一個(gè)任務(wù)可能會(huì)由于一個(gè)異常而結(jié)束蚁飒，因此它可能沒(méi)有 "成功"动壤。無(wú)法通過(guò)一個(gè) Future 對(duì)象來(lái)告知我們是兩種結(jié)束中的哪一種。
以下是一個(gè)代碼示例：

ExecutorService 關(guān)閉

使用完 ExecutorService 之后你應(yīng)該將其關(guān)閉淮逻，以使其中的線程不再運(yùn)行琼懊。
比如，如果你的應(yīng)用是通過(guò)一個(gè) main() 方法啟動(dòng)的爬早，之后 main 方法退出了你的應(yīng)用哼丈，如果你的應(yīng)用有一個(gè)活動(dòng)的 ExexutorService 它將還會(huì)保持運(yùn)行。ExecutorService 里的活動(dòng)線程阻止了 JVM 的關(guān)閉筛严。
要終止 ExecutorService 里的線程你需要調(diào)用 ExecutorService 的 shutdown() 方法醉旦。ExecutorService 并不會(huì)立即關(guān)閉，但它將不再接受新的任務(wù)桨啃，而且一旦所有線程都完成了當(dāng)前任務(wù)的時(shí)候车胡，ExecutorService 將會(huì)關(guān)閉。在 shutdown() 被調(diào)用之前所有提交給 ExecutorService 的任務(wù)都被執(zhí)行照瘾。

17. 線程池執(zhí)行者 ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor 是 ExecutorService 接口的一個(gè)實(shí)現(xiàn)匈棘。ThreadPoolExecutor 使用其內(nèi)部池中的線程執(zhí)行給定任務(wù)(Callable 或者 Runnable)。
ThreadPoolExecutor 包含的線程池能夠包含不同數(shù)量的線程析命。池中線程的數(shù)量由以下變量決定：

• corePoolSize
• maximumPoolSize

當(dāng)一個(gè)任務(wù)委托給線程池時(shí)主卫，如果池中線程數(shù)量低于 corePoolSize，一個(gè)新的線程將被創(chuàng)建碳却，即使池中可能尚有空閑線程。
如果內(nèi)部任務(wù)隊(duì)列已滿笑旺，而且有至少 corePoolSize 正在運(yùn)行昼浦，但是運(yùn)行線程的數(shù)量低于 maximumPoolSize，一個(gè)新的線程將被創(chuàng)建去執(zhí)行該任務(wù)筒主。
ThreadPoolExecutor 圖解：

thread-pool-executor

一個(gè) ThreadPoolExecutor

創(chuàng)建一個(gè) ThreadPoolExecutor

ThreadPoolExecutor 有若干個(gè)可用構(gòu)造子关噪。比如：

18. 定時(shí)執(zhí)行者服務(wù) ScheduledExecutorService

java.util.concurrent.ScheduledExecutorService 是一個(gè) ExecutorService鸟蟹， 它能夠?qū)⑷蝿?wù)延后執(zhí)行，或者間隔固定時(shí)間多次執(zhí)行使兔。 任務(wù)由一個(gè)工作者線程異步執(zhí)行建钥，而不是由提交任務(wù)給 ScheduledExecutorService 的那個(gè)線程執(zhí)行。

ScheduledExecutorService 例子

以下是一個(gè)簡(jiǎn)單的 ScheduledExecutorService 示例：

首先一個(gè)內(nèi)置 5 個(gè)線程的 ScheduledExecutorService 被創(chuàng)建虐沥。之后一個(gè) Callable 接口的匿名類示例被創(chuàng)建然后傳遞給 schedule() 方法熊经。后邊的倆參數(shù)定義了 Callable 將在 5 秒鐘之后被執(zhí)行。

ScheduledExecutorService 實(shí)現(xiàn)

既然 ScheduledExecutorService 是一個(gè)接口欲险，你要用它的話就得使用 java.util.concurrent 包里對(duì)它的某個(gè)實(shí)現(xiàn)類镐依。ScheduledExecutorService 具有以下實(shí)現(xiàn)類：

• ScheduledThreadPoolExecutor

創(chuàng)建一個(gè) ScheduledExecutorService

如何創(chuàng)建一個(gè) ScheduledExecutorService 取決于你采用的它的實(shí)現(xiàn)類。但是你也可以使用 Executors 工廠類來(lái)創(chuàng)建一個(gè) ScheduledExecutorService 實(shí)例天试。比如：

ScheduledExecutorService 使用

一旦你創(chuàng)建了一個(gè) ScheduledExecutorService槐壳，你可以通過(guò)調(diào)用它的以下方法：

• schedule (Callable task, long delay, TimeUnit timeunit)
• schedule (Runnable task, long delay, TimeUnit timeunit)
• scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit)
• scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit)

下面我們就簡(jiǎn)單看一下這些方法。

schedule (Callable task, long delay, TimeUnit timeunit)

這個(gè)方法計(jì)劃指定的 Callable 在給定的延遲之后執(zhí)行喜每。
這個(gè)方法返回一個(gè) ScheduledFuture务唐，通過(guò)它你可以在它被執(zhí)行之前對(duì)它進(jìn)行取消，或者在它執(zhí)行之后獲取結(jié)果带兜。
以下是一個(gè)示例：

示例輸出結(jié)果：
Executed!
result = Called!

schedule (Runnable task, long delay, TimeUnit timeunit)

除了 Runnable 無(wú)法返回一個(gè)結(jié)果之外枫笛，這一方法工作起來(lái)就像以一個(gè) Callable 作為一個(gè)參數(shù)的那個(gè)版本的方法一樣，因此 ScheduledFuture.get() 在任務(wù)執(zhí)行結(jié)束之后返回 null鞋真。

scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit)

這一方法規(guī)劃一個(gè)任務(wù)將被定期執(zhí)行崇堰。該任務(wù)將會(huì)在首個(gè) initialDelay 之后得到執(zhí)行，然后每個(gè) period 時(shí)間之后重復(fù)執(zhí)行涩咖。
如果給定任務(wù)的執(zhí)行拋出了異常海诲，該任務(wù)將不再執(zhí)行。如果沒(méi)有任何異常的話檩互，這個(gè)任務(wù)將會(huì)持續(xù)循環(huán)執(zhí)行到 ScheduledExecutorService 被關(guān)閉特幔。
如果一個(gè)任務(wù)占用了比計(jì)劃的時(shí)間間隔更長(zhǎng)的時(shí)候，下一次執(zhí)行將在當(dāng)前執(zhí)行結(jié)束執(zhí)行才開始闸昨。計(jì)劃任務(wù)在同一時(shí)間不會(huì)有多個(gè)線程同時(shí)執(zhí)行蚯斯。

scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit)

除了 period 有不同的解釋之外這個(gè)方法和 scheduleAtFixedRate() 非常像。
scheduleAtFixedRate() 方法中饵较，period 被解釋為前一個(gè)執(zhí)行的開始和下一個(gè)執(zhí)行的開始之間的間隔時(shí)間拍嵌。
而在本方法中，period 則被解釋為前一個(gè)執(zhí)行的結(jié)束和下一個(gè)執(zhí)行的結(jié)束之間的間隔循诉。因此這個(gè)延遲是執(zhí)行結(jié)束之間的間隔横辆，而不是執(zhí)行開始之間的間隔。

ScheduledExecutorService 關(guān)閉

正如 ExecutorService茄猫，在你使用結(jié)束之后你需要把 ScheduledExecutorService 關(guān)閉掉狈蚤。否則他將導(dǎo)致 JVM 繼續(xù)運(yùn)行困肩，即使所有其他線程已經(jīng)全被關(guān)閉。

19. 使用 ForkJoinPool 進(jìn)行分叉和合并

ForkJoinPool 在 Java 7 中被引入脆侮。它和 ExecutorService 很相似锌畸，除了一點(diǎn)不同。ForkJoinPool 讓我們可以很方便地把任務(wù)分裂成幾個(gè)更小的任務(wù)靖避，這些分裂出來(lái)的任務(wù)也將會(huì)提交給 ForkJoinPool潭枣。任務(wù)可以繼續(xù)分割成更小的子任務(wù)，只要它還能分割筋蓖⌒对牛可能聽起來(lái)有些抽象，因此本節(jié)中我們將會(huì)解釋 ForkJoinPool 是如何工作的粘咖，還有任務(wù)分割是如何進(jìn)行的蚣抗。

分叉和合并解釋

在我們開始看 ForkJoinPool 之前我們先來(lái)簡(jiǎn)要解釋一下分叉和合并的原理。
分叉和合并原理包含兩個(gè)遞歸進(jìn)行的步驟瓮下。兩個(gè)步驟分別是分叉步驟和合并步驟翰铡。

分叉

一個(gè)使用了分叉和合并原理的任務(wù)可以將自己分叉(分割)為更小的子任務(wù)，這些子任務(wù)可以被并發(fā)執(zhí)行讽坏。如下圖所示：

java-fork-and-join-1

通過(guò)把自己分割成多個(gè)子任務(wù)锭魔，每個(gè)子任務(wù)可以由不同的 CPU 并行執(zhí)行，或者被同一個(gè) CPU 上的不同線程執(zhí)行路呜。
只有當(dāng)給的任務(wù)過(guò)大迷捧，把它分割成幾個(gè)子任務(wù)才有意義。把任務(wù)分割成子任務(wù)有一定開銷胀葱，因此對(duì)于小型任務(wù)漠秋，這個(gè)分割的消耗可能比每個(gè)子任務(wù)并發(fā)執(zhí)行的消耗還要大。
什么時(shí)候把一個(gè)任務(wù)分割成子任務(wù)是有意義的抵屿，這個(gè)界限也稱作一個(gè)閥值庆锦。這要看每個(gè)任務(wù)對(duì)有意義閥值的決定。很大程度上取決于它要做的工作的種類轧葛。

合并

當(dāng)一個(gè)任務(wù)將自己分割成若干子任務(wù)之后搂抒，該任務(wù)將進(jìn)入等待所有子任務(wù)的結(jié)束之中。
一旦子任務(wù)執(zhí)行結(jié)束尿扯，該任務(wù)可以把所有結(jié)果合并到同一個(gè)結(jié)果求晶。圖示如下：

java-fork-and-join-2

當(dāng)然，并非所有類型的任務(wù)都會(huì)返回一個(gè)結(jié)果衷笋。如果這個(gè)任務(wù)并不返回一個(gè)結(jié)果芳杏，它只需等待所有子任務(wù)執(zhí)行完畢。也就不需要結(jié)果的合并啦。

ForkJoinPool

ForkJoinPool 是一個(gè)特殊的線程池蚜锨，它的設(shè)計(jì)是為了更好的配合 分叉-和-合并 任務(wù)分割的工作。ForkJoinPool 也在 java.util.concurrent 包中慢蜓，其完整類名為 java.util.concurrent.ForkJoinPool亚再。

創(chuàng)建一個(gè) ForkJoinPool

你可以通過(guò)其構(gòu)造子創(chuàng)建一個(gè) ForkJoinPool。作為傳遞給 ForkJoinPool 構(gòu)造子的一個(gè)參數(shù)晨抡，你可以定義你期望的并行級(jí)別氛悬。并行級(jí)別表示你想要傳遞給 ForkJoinPool 的任務(wù)所需的線程或 CPU 數(shù)量。以下是一個(gè) ForkJoinPool 示例：

這個(gè)示例創(chuàng)建了一個(gè)并行級(jí)別為 4 的 ForkJoinPool耘柱。

提交任務(wù)到 ForkJoinPool

就像提交任務(wù)到 ExecutorService 那樣如捅，把任務(wù)提交到 ForkJoinPool。你可以提交兩種類型的任務(wù)调煎。一種是沒(méi)有任何返回值的(一個(gè) "行動(dòng)")镜遣，另一種是有返回值的(一個(gè)"任務(wù)")。這兩種類型分別由 RecursiveAction 和 RecursiveTask 表示士袄。接下來(lái)介紹如何使用這兩種類型的任務(wù)悲关，以及如何對(duì)它們進(jìn)行提交。

RecursiveAction

RecursiveAction 是一種沒(méi)有任何返回值的任務(wù)娄柳。它只是做一些工作寓辱，比如寫數(shù)據(jù)到磁盤，然后就退出了赤拒。
一個(gè) RecursiveAction 可以把自己的工作分割成更小的幾塊秫筏，這樣它們可以由獨(dú)立的線程或者 CPU 執(zhí)行。
你可以通過(guò)繼承來(lái)實(shí)現(xiàn)一個(gè) RecursiveAction挎挖。示例如下：

例子很簡(jiǎn)單这敬。MyRecursiveAction 將一個(gè)虛構(gòu)的 workLoad 作為參數(shù)傳給自己的構(gòu)造子。如果 workLoad 高于一個(gè)特定閥值肋乍，該工作將被分割為幾個(gè)子工作鹅颊，子工作繼續(xù)分割。如果 workLoad 低于特定閥值墓造，該工作將由 MyRecursiveAction 自己執(zhí)行堪伍。
你可以這樣規(guī)劃一個(gè) MyRecursiveAction 的執(zhí)行：

RecursiveTask

RecursiveTask 是一種會(huì)返回結(jié)果的任務(wù)。它可以將自己的工作分割為若干更小任務(wù)觅闽，并將這些子任務(wù)的執(zhí)行結(jié)果合并到一個(gè)集體結(jié)果帝雇。可以有幾個(gè)水平的分割和合并蛉拙。以下是一個(gè) RecursiveTask 示例：

除了有一個(gè)結(jié)果返回之外尸闸，這個(gè)示例和 RecursiveAction 的例子很像。MyRecursiveTask 類繼承自 RecursiveTask<Long>，這也就意味著它將返回一個(gè) Long 類型的結(jié)果吮廉。
MyRecursiveTask 示例也會(huì)將工作分割為子任務(wù)苞尝，并通過(guò) fork() 方法對(duì)這些子任務(wù)計(jì)劃執(zhí)行。
此外宦芦，本示例還通過(guò)調(diào)用每個(gè)子任務(wù)的 join() 方法收集它們返回的結(jié)果宙址。子任務(wù)的結(jié)果隨后被合并到一個(gè)更大的結(jié)果，并最終將其返回调卑。對(duì)于不同級(jí)別的遞歸抡砂，這種子任務(wù)的結(jié)果合并可能會(huì)發(fā)生遞歸。
你可以這樣規(guī)劃一個(gè) RecursiveTask：

注意是如何通過(guò) ForkJoinPool.invoke() 方法的調(diào)用來(lái)獲取最終執(zhí)行結(jié)果的恬涧。

ForkJoinPool 評(píng)論

貌似并非每個(gè)人都對(duì) Java 7 里的 ForkJoinPool 滿意：《一個(gè) Java 分叉-合并 帶來(lái)的災(zāi)禍》注益。

20. 鎖 Lock

java.util.concurrent.locks.Lock 是一個(gè)類似于 synchronized 塊的線程同步機(jī)制。但是 Lock 比 synchronized 塊更加靈活溯捆、精細(xì)丑搔。
順便說(shuō)一下，在我的《Java 并發(fā)指南》中我對(duì)如何實(shí)現(xiàn)你自己的鎖進(jìn)行了描述提揍。

Java Lock 例子

既然 Lock 是一個(gè)接口低匙，在你的程序里需要使用它的實(shí)現(xiàn)類之一來(lái)使用它。以下是一個(gè)簡(jiǎn)單示例：

首先創(chuàng)建了一個(gè) Lock 對(duì)象碳锈。之后調(diào)用了它的 lock() 方法顽冶。這時(shí)候這個(gè) lock 實(shí)例就被鎖住啦。任何其他再過(guò)來(lái)調(diào)用 lock() 方法的線程將會(huì)被阻塞住售碳，直到鎖定 lock 實(shí)例的線程調(diào)用了 unlock() 方法强重。最后 unlock() 被調(diào)用了，lock 對(duì)象解鎖了贸人，其他線程可以對(duì)它進(jìn)行鎖定了间景。

Java Lock 實(shí)現(xiàn)

java.util.concurrent.locks 包提供了以下對(duì) Lock 接口的實(shí)現(xiàn)類：

• ReentrantLock

Lock 和 synchronized 代碼塊的主要不同點(diǎn)

一個(gè) Lock 對(duì)象和一個(gè) synchronized 代碼塊之間的主要不同點(diǎn)是：

• synchronized 代碼塊不能夠保證進(jìn)入訪問(wèn)等待的線程的先后順序。
• 你不能夠傳遞任何參數(shù)給一個(gè) synchronized 代碼塊的入口艺智。因此倘要，對(duì)于 synchronized 代碼塊的訪問(wèn)等待設(shè)置超時(shí)時(shí)間是不可能的事情。
• synchronized 塊必須被完整地包含在單個(gè)方法里十拣。而一個(gè) Lock 對(duì)象可以把它的 lock() 和 unlock() 方法的調(diào)用放在不同的方法里封拧。

Lock 的方法

Lock 接口具有以下主要方法：

• lock()
• lockInterruptibly()
• tryLock()
• tryLock(long timeout, TimeUnit timeUnit)
• unlock()

lock() 將 Lock 實(shí)例鎖定。如果該 Lock 實(shí)例已被鎖定夭问，調(diào)用 lock() 方法的線程將會(huì)阻塞泽西，直到 Lock 實(shí)例解鎖。
lockInterruptibly() 方法將會(huì)被調(diào)用線程鎖定缰趋，除非該線程被打斷捧杉。此外陕见，如果一個(gè)線程在通過(guò)這個(gè)方法來(lái)鎖定 Lock 對(duì)象時(shí)進(jìn)入阻塞等待，而它被打斷了的話味抖，該線程將會(huì)退出這個(gè)方法調(diào)用评甜。
tryLock() 方法試圖立即鎖定 Lock 實(shí)例。如果鎖定成功仔涩，它將返回 true蜕着，如果 Lock 實(shí)例已被鎖定該方法返回 false。這一方法永不阻塞红柱。
tryLock(long timeout, TimeUnit timeUnit) 的工作類似于 tryLock() 方法，除了它在放棄鎖定 Lock 之前等待一個(gè)給定的超時(shí)時(shí)間之外蓖乘。

21. 讀寫鎖 ReadWriteLock

java.util.concurrent.locks.ReadWriteLock 讀寫鎖是一種先進(jìn)的線程鎖機(jī)制锤悄。它能夠允許多個(gè)線程在同一時(shí)間對(duì)某特定資源進(jìn)行讀取，但同一時(shí)間內(nèi)只能有一個(gè)線程對(duì)其進(jìn)行寫入嘉抒。
讀寫鎖的理念在于多個(gè)線程能夠?qū)σ粋€(gè)共享資源進(jìn)行讀取零聚，而不會(huì)導(dǎo)致并發(fā)問(wèn)題。并發(fā)問(wèn)題的發(fā)生場(chǎng)景在于對(duì)一個(gè)共享資源的讀和寫操作的同時(shí)進(jìn)行些侍，或者多個(gè)寫操作并發(fā)進(jìn)行隶症。
本節(jié)只討論 Java 內(nèi)置 ReadWriteLock。如果你想了解 ReadWriteLock 背后的實(shí)現(xiàn)原理岗宣，請(qǐng)參考我的《Java 并發(fā)指南》主題中的《讀寫鎖》小節(jié)蚂会。

ReadWriteLock 鎖規(guī)則

一個(gè)線程在對(duì)受保護(hù)資源在讀或者寫之前對(duì) ReadWriteLock 鎖定的規(guī)則如下：

• 讀鎖：如果沒(méi)有任何寫操作線程鎖定 ReadWriteLock，并且沒(méi)有任何寫操作線程要求一個(gè)寫鎖(但還沒(méi)有獲得該鎖)耗式。因此胁住，可以有多個(gè)讀操作線程對(duì)該鎖進(jìn)行鎖定。
• 寫鎖：如果沒(méi)有任何讀操作或者寫操作刊咳。因此彪见，在寫操作的時(shí)候，只能有一個(gè)線程對(duì)該鎖進(jìn)行鎖定娱挨。

ReadWriteLock 實(shí)現(xiàn)

ReadWriteLock 是個(gè)接口余指，如果你想用它的話就得去使用它的實(shí)現(xiàn)類之一。java.util.concurrent.locks 包提供了 ReadWriteLock 接口的以下實(shí)現(xiàn)類：

• ReentrantReadWriteLock

ReadWriteLock 代碼示例

以下是 ReadWriteLock 的創(chuàng)建以及如何使用它進(jìn)行讀跷坝、寫鎖定的簡(jiǎn)單示例代碼：

22. 原子性布爾 AtomicBoolean

AtomicBoolean 類為我們提供了一個(gè)可以用原子方式進(jìn)行讀和寫的布爾值酵镜，它還擁有一些先進(jìn)的原子性操作，比如 compareAndSet()柴钻。AtomicBoolean 類位于 java.util.concurrent.atomic 包笋婿，完整類名是為 java.util.concurrent.atomic.AtomicBoolean。本小節(jié)描述的 AtomicBoolean 是 Java 8 版本里的顿颅，而不是它第一次被引入的 Java 5 版本缸濒。
AtomicBoolean 背后的設(shè)計(jì)理念在我的《Java 并發(fā)指南》主題的《比較和交換》小節(jié)有解釋足丢。

創(chuàng)建一個(gè) AtomicBoolean

你可以這樣創(chuàng)建一個(gè) AtomicBoolean：

以上示例新建了一個(gè)默認(rèn)值為 false 的 AtomicBoolean。
如果你想要為 AtomicBoolean 實(shí)例設(shè)置一個(gè)顯式的初始值庇配，那么你可以將初始值傳給 AtomicBoolean 的構(gòu)造子：

獲取 AtomicBoolean 的值

你可以通過(guò)使用 get() 方法來(lái)獲取一個(gè) AtomicBoolean 的值斩跌。示例如下：

以上代碼執(zhí)行后 value 變量的值將為 true。

設(shè)置 AtomicBoolean 的值

你可以通過(guò)使用 set() 方法來(lái)設(shè)置一個(gè) AtomicBoolean 的值捞慌。示例如下：

以上代碼執(zhí)行后 AtomicBoolean 的值為 false耀鸦。

交換 AtomicBoolean 的值

你可以通過(guò) getAndSet() 方法來(lái)交換一個(gè) AtomicBoolean 實(shí)例的值。getAndSet() 方法將返回 AtomicBoolean 當(dāng)前的值啸澡，并將為 AtomicBoolean 設(shè)置一個(gè)新值袖订。示例如下：

以上代碼執(zhí)行后 oldValue 變量的值為 true，atomicBoolean 實(shí)例將持有 false 值嗅虏。代碼成功將 AtomicBoolean 當(dāng)前值 ture 交換為 false洛姑。

比較并設(shè)置 AtomicBoolean 的值

compareAndSet() 方法允許你對(duì) AtomicBoolean 的當(dāng)前值與一個(gè)期望值進(jìn)行比較，如果當(dāng)前值等于期望值的話皮服，將會(huì)對(duì) AtomicBoolean 設(shè)定一個(gè)新值楞艾。compareAndSet() 方法是原子性的，因此在同一時(shí)間之內(nèi)有單個(gè)線程執(zhí)行它龄广。因此 compareAndSet() 方法可被用于一些類似于鎖的同步的簡(jiǎn)單實(shí)現(xiàn)硫眯。
以下是一個(gè) compareAndSet() 示例：

23. 原子性整型 AtomicInteger

AtomicInteger 類為我們提供了一個(gè)可以進(jìn)行原子性讀和寫操作的 int 變量，它還包含一系列先進(jìn)的原子性操作择同，比如 compareAndSet()两入。AtomicInteger 類位于 java.util.concurrent.atomic 包，因此其完整類名為 java.util.concurrent.atomic.AtomicInteger敲才。本小節(jié)描述的 AtomicInteger 是 Java 8 版本里的谆刨，而不是它第一次被引入的 Java 5 版本。
AtomicInteger 背后的設(shè)計(jì)理念在我的《Java 并發(fā)指南》主題的《比較和交換》小節(jié)有解釋归斤。

創(chuàng)建一個(gè) AtomicInteger

創(chuàng)建一個(gè) AtomicInteger 示例如下：

本示例將創(chuàng)建一個(gè)初始值為 0 的 AtomicInteger痊夭。
如果你想要?jiǎng)?chuàng)建一個(gè)給定初始值的 AtomicInteger，你可以這樣：

本示例將 123 作為參數(shù)傳給 AtomicInteger 的構(gòu)造子脏里，它將設(shè)置 AtomicInteger 實(shí)例的初始值為 123她我。

獲取 AtomicInteger 的值

你可以使用 get() 方法獲取 AtomicInteger 實(shí)例的值。示例如下：

設(shè)置 AtomicInteger 的值

你可以通過(guò) set() 方法對(duì) AtomicInteger 的值進(jìn)行重新設(shè)置迫横。以下是 AtomicInteger.set() 示例：

以上示例創(chuàng)建了一個(gè)初始值為 123 的 AtomicInteger番舆，而在第二行將其值更新為 234。

比較并設(shè)置 AtomicInteger 的值

AtomicInteger 類也通過(guò)了一個(gè)原子性的 compareAndSet() 方法矾踱。這一方法將 AtomicInteger 實(shí)例的當(dāng)前值與期望值進(jìn)行比較恨狈，如果二者相等，為 AtomicInteger 實(shí)例設(shè)置一個(gè)新值呛讲。AtomicInteger.compareAndSet() 代碼示例：

本示例首先新建一個(gè)初始值為 123 的 AtomicInteger 實(shí)例禾怠。然后將 AtomicInteger 與期望值 123 進(jìn)行比較返奉，如果相等，將 AtomicInteger 的值更新為 234吗氏。

增加 AtomicInteger 值

AtomicInteger 類包含有一些方法芽偏，通過(guò)它們你可以增加 AtomicInteger 的值，并獲取其值弦讽。這些方法如下：

• addAndGet()
• getAndAdd()
• getAndIncrement()
• incrementAndGet()

第一個(gè) addAndGet() 方法給 AtomicInteger 增加了一個(gè)值污尉，然后返回增加后的值。getAndAdd() 方法為 AtomicInteger 增加了一個(gè)值往产，但返回的是增加以前的 AtomicInteger 的值被碗。具體使用哪一個(gè)取決于你的應(yīng)用場(chǎng)景。以下是這兩種方法的示例：

本示例將打印出 0 和 20仿村。例子中锐朴，第二行拿到的是加 10 之前的 AtomicInteger 的值。加 10 之前的值是 0奠宜。第三行將 AtomicInteger 的值再加 10，并返回加操作之后的值瞻想。該值現(xiàn)在是為 20压真。
你當(dāng)然也可以使用這倆方法為 AtomicInteger 添加負(fù)值。結(jié)果實(shí)際是一個(gè)減法操作蘑险。
getAndIncrement() 和 incrementAndGet() 方法類似于 getAndAdd() 和 addAndGet()滴肿，但每次只將 AtomicInteger 的值加 1。

減小 AtomicInteger 的值

AtomicInteger 類還提供了一些減小 AtomicInteger 的值的原子性方法佃迄。這些方法是：

• decrementAndGet()
• getAndDecrement()

24. 原子性長(zhǎng)整型 AtomicLong

AtomicLong 類為我們提供了一個(gè)可以進(jìn)行原子性讀和寫操作的 long 變量泼差，它還包含一系列先進(jìn)的原子性操作，比如 compareAndSet()AtomicLong 類位于 java.util.concurrent.atomic 包呵俏，因此其完整類名為 java.util.concurrent.atomic.AtomicLong堆缘。本小節(jié)描述的 AtomicLong 是 Java 8 版本里的，而不是它第一次被引入的 Java 5 版本普碎。
AtomicLong 背后的設(shè)計(jì)理念在我的《Java 并發(fā)指南》主題的《比較和交換》小節(jié)有解釋吼肥。

創(chuàng)建一個(gè) AtomicLong

創(chuàng)建一個(gè) AtomicLong 如下：

將創(chuàng)建一個(gè)初始值為 0 的 AtomicLong。
如果你想創(chuàng)建一個(gè)指定初始值的 AtomicLong麻车，可以：

本示例將 123 作為參數(shù)傳遞給 AtomicLong 的構(gòu)造子缀皱，后者將 AtomicLong 實(shí)例的初始值設(shè)置為 123。

獲取 AtomicLong 的值

你可以通過(guò) get() 方法獲取 AtomicLong 的值动猬。AtomicLong.get() 示例：

設(shè)置 AtomicLong 的值

你可以通過(guò) set() 方法設(shè)置 AtomicLong 實(shí)例的值啤斗。一個(gè) AtomicLong.set() 的示例：

本示例新建了一個(gè)初始值為 123 的 AtomicLong，第二行將其值設(shè)置為 234赁咙。

比較并設(shè)置 AtomicLong 的值

本示例新建了一個(gè)初始值為 123 的 AtomicLong钮莲。然后將 AtomicLong 的當(dāng)前值與期望值 123 進(jìn)行比較免钻，如果相等的話，AtomicLong 的新值將變?yōu)?234臂痕。

增加 AtomicLong 值

AtomicLong 具備一些能夠增加 AtomicLong 的值并返回自身值的方法伯襟。這些方法如下：

• addAndGet()
• getAndAdd()
• getAndIncrement()
• incrementAndGet()

第一個(gè)方法 addAndGet() 將 AtomicLong 的值加一個(gè)數(shù)字，并返回增加后的值握童。第二個(gè)方法 getAndAdd() 也將 AtomicLong 的值加一個(gè)數(shù)字姆怪，但返回的是增加前的 AtomicLong 的值。具體使用哪一個(gè)取決于你自己的場(chǎng)景澡绩。示例如下：

本示例將打印出 0 和 20稽揭。例子中，第二行拿到的是加 10 之前的 AtomicLong 的值肥卡。加 10 之前的值是 0溪掀。第三行將 AtomicLong 的值再加 10，并返回加操作之后的值步鉴。該值現(xiàn)在是為 20揪胃。
你當(dāng)然也可以使用這倆方法為 AtomicLong 添加負(fù)值。結(jié)果實(shí)際是一個(gè)減法操作氛琢。
getAndIncrement() 和 incrementAndGet() 方法類似于 getAndAdd() 和 addAndGet()喊递，但每次只將 AtomicLong 的值加 1。

減小 AtomicLong 的值

AtomicLong 類還提供了一些減小 AtomicLong 的值的原子性方法阳似。這些方法是：

• decrementAndGet()
• getAndDecrement()

25. 原子性引用型 AtomicReference

AtomicReference 提供了一個(gè)可以被原子性讀和寫的對(duì)象引用變量骚勘。原子性的意思是多個(gè)想要改變同一個(gè) AtomicReference 的線程不會(huì)導(dǎo)致 AtomicReference 處于不一致的狀態(tài)。AtomicReference 還有一個(gè) compareAndSet() 方法撮奏，通過(guò)它你可以將當(dāng)前引用于一個(gè)期望值(引用)進(jìn)行比較俏讹，如果相等，在該 AtomicReference 對(duì)象內(nèi)部設(shè)置一個(gè)新的引用畜吊。

創(chuàng)建一個(gè) AtomicReference

創(chuàng)建 AtomicReference 如下：

如果你需要使用一個(gè)指定引用創(chuàng)建 AtomicReference泽疆，可以：

創(chuàng)建泛型 AtomicReference

你可以使用 Java 泛型來(lái)創(chuàng)建一個(gè)泛型 AtomicReference。示例：

你也可以為泛型 AtomicReference 設(shè)置一個(gè)初始值玲献。示例：

獲取 AtomicReference 引用

你可以通過(guò) AtomicReference 的 get() 方法來(lái)獲取保存在 AtomicReference 里的引用于微。如果你的 AtomicReference 是非泛型的，get() 方法將返回一個(gè) Object 類型的引用青自。如果是泛型化的株依，get() 將返回你創(chuàng)建 AtomicReference 時(shí)聲明的那個(gè)類型。
先來(lái)看一個(gè)非泛型的 AtomicReference get() 示例：

注意如何對(duì) get() 方法返回的引用強(qiáng)制轉(zhuǎn)換為 String延窜。
泛型化的 AtomicReference 示例：

編譯器知道了引用的類型恋腕，所以我們無(wú)需再對(duì) get() 返回的引用進(jìn)行強(qiáng)制轉(zhuǎn)換了。

設(shè)置 AtomicReference 引用

你可以使用 get() 方法對(duì) AtomicReference 里邊保存的引用進(jìn)行設(shè)置逆瑞。如果你定義的是一個(gè)非泛型 AtomicReference荠藤，set() 將會(huì)以一個(gè) Object 引用作為參數(shù)伙单。如果是泛型化的 AtomicReference，set() 方法將只接受你定義給的類型哈肖。
AtomicReference set() 示例：

這個(gè)看起來(lái)非泛型和泛型化的沒(méi)啥區(qū)別吻育。真正的區(qū)別在于編譯器將對(duì)你能夠設(shè)置給一個(gè)泛型化的 AtomicReference 參數(shù)類型進(jìn)行限制。

比較并設(shè)置 AtomicReference 引用

AtomicReference 類具備了一個(gè)很有用的方法：compareAndSet()淤井。compareAndSet() 可以將保存在 AtomicReference 里的引用于一個(gè)期望引用進(jìn)行比較践宴，如果兩個(gè)引用是一樣的(并非 equals() 的相等邓线，而是 == 的一樣)肛著，將會(huì)給 AtomicReference 實(shí)例設(shè)置一個(gè)新的引用篷帅。
如果 compareAndSet() 為 AtomicReference 設(shè)置了一個(gè)新的引用，compareAndSet() 將返回 true漩绵。否則 compareAndSet() 返回 false贱案。
AtomicReference compareAndSet() 示例：

本示例創(chuàng)建了一個(gè)帶有一個(gè)初始引用的泛型化的 AtomicReference。之后兩次調(diào)用 comparesAndSet()來(lái)對(duì)存儲(chǔ)值和期望值進(jìn)行對(duì)比止吐，如果二者一致，為 AtomicReference 設(shè)置一個(gè)新的引用套鹅。第一次比較吟孙，存儲(chǔ)的引用(initialReference)和期望的引用(initialReference)一致碘勉，所以一個(gè)新的引用(newReference)被設(shè)置給 AtomicReference高职，compareAndSet() 方法返回 true产禾。第二次比較時(shí)衫生，存儲(chǔ)的引用(newReference)和期望的引用(initialReference)不一致泪酱，因此新的引用沒(méi)有被設(shè)置給 AtomicReference斯撮，compareAndSet() 方法返回 false。