免费A级毛片无码专区网站-成人国产精品视频一区二区-啊 日出水了 用力乖乖在线-国产黑色丝袜在线观看下-天天操美女夜夜操美女-日韩网站在线观看中文字幕-AV高清hd片XXX国产-亚洲av中文字字幕乱码综合-搬开女人下面使劲插视频

  1. 首頁 > 生活 > >

什么是ForkJoin？看這一篇就能掌握！( 二 )

生活百科


ForkJoinPool主要使用**分治法(Divide-and-Conquer Algorithm)**來解決問題 。典型的應(yīng)用比如快速排序算法 。這里的要點(diǎn)在于，F(xiàn)orkJoinPool能夠使用相對(duì)較少的線程來處理大量的任務(wù) 。比如要對(duì)1000萬個(gè)數(shù)據(jù)進(jìn)行排序，那么會(huì)將這個(gè)任務(wù)分割成兩個(gè)500萬的排序任務(wù)和一個(gè)針對(duì)這兩組500萬數(shù)據(jù)的合并任務(wù) 。以此類推，對(duì)于500萬的數(shù)據(jù)也會(huì)做出同樣的分割處理，到最后會(huì)設(shè)置一個(gè)閾值來規(guī)定當(dāng)數(shù)據(jù)規(guī)模到多少時(shí)，停止這樣的分割處理 。比如，當(dāng)元素的數(shù)量小于10時(shí)，會(huì)停止分割，轉(zhuǎn)而使用插入排序?qū)λ鼈冞M(jìn)行排序 。那么到最后，所有的任務(wù)加起來會(huì)有大概200萬+個(gè) 。問題的關(guān)鍵在于，對(duì)于一個(gè)任務(wù)而言，只有當(dāng)它所有的子任務(wù)完成之后，它才能夠被執(zhí)行 。
所以當(dāng)使用ThreadPoolExecutor時(shí)，使用分治法會(huì)存在問題，因?yàn)門hreadPoolExecutor中的線程無法向任務(wù)隊(duì)列中再添加一個(gè)任務(wù)并在等待該任務(wù)完成之后再繼續(xù)執(zhí)行 。而使用ForkJoinPool就能夠解決這個(gè)問題，它就能夠讓其中的線程創(chuàng)建新的任務(wù)，并掛起當(dāng)前的任務(wù)，此時(shí)線程就能夠從隊(duì)列中選擇子任務(wù)執(zhí)行 。
那么使用ThreadPoolExecutor或者ForkJoinPool，性能上會(huì)有什么差異呢？
首先，使用ForkJoinPool能夠使用數(shù)量有限的線程來完成非常多的具有父子關(guān)系的任務(wù)，比如使用4個(gè)線程來完成超過200萬個(gè)任務(wù) 。但是，使用ThreadPoolExecutor時(shí)，是不可能完成的，因?yàn)門hreadPoolExecutor中的Thread無法選擇優(yōu)先執(zhí)行子任務(wù)，需要完成200萬個(gè)具有父子關(guān)系的任務(wù)時(shí)，也需要200萬個(gè)線程，很顯然這是不可行的，也是很不合理的??！
工作竊取算法假如我們需要做一個(gè)比較大的任務(wù)，我們可以把這個(gè)任務(wù)分割為若干互不依賴的子任務(wù)，為了減少線程間的競爭，于是把這些子任務(wù)分別放到不同的隊(duì)列里，并為每個(gè)隊(duì)列創(chuàng)建一個(gè)單獨(dú)的線程來執(zhí)行隊(duì)列里的任務(wù)，線程和隊(duì)列一一對(duì)應(yīng)，比如A線程負(fù)責(zé)處理A隊(duì)列里的任務(wù) 。但是有的線程會(huì)先把自己隊(duì)列里的任務(wù)干完，而其他線程對(duì)應(yīng)的隊(duì)列里還有任務(wù)等待處理 。干完活的線程與其等著，不如去幫其他線程干活，于是它就去其他線程的隊(duì)列里竊取一個(gè)任務(wù)來執(zhí)行 。而在這時(shí)它們會(huì)訪問同一個(gè)隊(duì)列，所以為了減少竊取任務(wù)線程和被竊取任務(wù)線程之間的競爭，通常會(huì)使用雙端隊(duì)列，被竊取任務(wù)線程永遠(yuǎn)從雙端隊(duì)列的頭部拿任務(wù)執(zhí)行，而竊取任務(wù)的線程永遠(yuǎn)從雙端隊(duì)列的尾部拿任務(wù)執(zhí)行 。
工作竊取算法的優(yōu)點(diǎn)：
充分利用線程進(jìn)行并行計(jì)算，并減少了線程間的競爭 。
工作竊取算法的缺點(diǎn)：
在某些情況下還是存在競爭，比如雙端隊(duì)列里只有一個(gè)任務(wù)時(shí) 。并且該算法會(huì)消耗更多的系統(tǒng)資源，比如創(chuàng)建多個(gè)線程和多個(gè)雙端隊(duì)列 。
Fork/Join框架局限性：
對(duì)于Fork/Join框架而言，當(dāng)一個(gè)任務(wù)正在等待它使用Join操作創(chuàng)建的子任務(wù)結(jié)束時(shí)，執(zhí)行這個(gè)任務(wù)的工作線程查找其他未被執(zhí)行的任務(wù)，并開始執(zhí)行這些未被執(zhí)行的任務(wù)，通過這種方式，線程充分利用它們的運(yùn)行時(shí)間來提高應(yīng)用程序的性能 。為了實(shí)現(xiàn)這個(gè)目標(biāo)，F(xiàn)ork/Join框架執(zhí)行的任務(wù)有一些局限性 。
（1）任務(wù)只能使用Fork和Join操作來進(jìn)行同步機(jī)制，如果使用了其他同步機(jī)制，則在同步操作時(shí)，工作線程就不能執(zhí)行其他任務(wù)了 。比如，在Fork/Join框架中，使任務(wù)進(jìn)行了睡眠，那么，在睡眠期間內(nèi)，正在執(zhí)行這個(gè)任務(wù)的工作線程將不會(huì)執(zhí)行其他任務(wù)了 。（2）在Fork/Join框架中，所拆分的任務(wù)不應(yīng)該去執(zhí)行IO操作，比如：讀寫數(shù)據(jù)文件 。（3）任務(wù)不能拋出檢查異常，必須通過必要的代碼來出來這些異常 。
ForkJoin框架的實(shí)現(xiàn)ForkJoin框架中一些重要的類如下所示 。

經(jīng)驗(yàn)總結(jié)擴(kuò)展閱讀