問:除過常見的 wait、notify与学、顯示 Condition 并發(fā)協(xié)作方式外你還知道哪些 java 的并發(fā)協(xié)作工具類?
答:
CountDownLatch:允許一個或者多個線程等待其他線程完成操作吮便,平時我們在主線程等待其他線程結(jié)束一般都是在主線程調(diào)用其他 Thread 的 join 方法進(jìn)行阻塞等待滤钱,而 join 的實質(zhì)就是循環(huán)判斷線程 isAlive 就進(jìn)行 wait 操作,直到被 join 的線程終止后線程的 this.notifyAll 方法(JVM實現(xiàn)斩萌,外部不可見)會被調(diào)用進(jìn)而觸發(fā) wait 結(jié)束而使 join 阻塞退出缝裤;并發(fā)包提供的 CountDownLatch 也可以實現(xiàn) join 的功能状囱,而且還提供了比 join 更多的功能,CountDownLatch 構(gòu)造函數(shù)接收一個 int 參數(shù)作為計數(shù)器倘是,如果你想等待 N 個計數(shù)點完成就傳 N,當(dāng)我們每個點完成時調(diào)用 CountDownLatch 的 countDown 方法則 N 就會自動減一袭艺,CountDownLatch 的 await 會阻塞當(dāng)前線程直到 N 變?yōu)榱銥橹共笳福洳捎?CAS 和 AQS(AbstractQueuedSynchronizer)實現(xiàn)。
CyclicBarrier:同步可循換使用的屏障猾编,讓一組線程到達(dá)一個屏障(同步點)時被阻塞瘤睹,直到最后一個線程到達(dá)屏障時才會開門,所有被屏障攔截的線程才會繼續(xù)干活答倡;CyclicBarrier 默認(rèn)的構(gòu)造方法是 CyclicBarrier(int parties)轰传,其參數(shù)表示屏障攔截的線程數(shù)量,每個線程調(diào)用 await 方法告訴 CyclicBarrier 我已經(jīng)到達(dá)了屏障瘪撇,然后當(dāng)前線程被阻塞获茬;CyclicBarrier 還提供一個高級構(gòu)造函數(shù) CyclicBarrier(int parties, Runnable barrierAction) 用于在線程到達(dá)屏障時優(yōu)先執(zhí)行 barrierAction,方便處理復(fù)雜的業(yè)務(wù)場景倔既;CyclicBarrier 適合并發(fā)計算數(shù)據(jù)匯總場景恕曲,其與 CountDownLatch 的主要區(qū)別是 CyclicBarrier 計數(shù)器可以 reset 而 CountDownLatch 只能用一次,其次 CyclicBarrier 提供了比 CountDownLatch 多的操作方法渤涌。
Semaphore:信號量佩谣,用來控制同時訪問特定資源的線程數(shù)量,它通過協(xié)調(diào)各個線程以保證合理的使用公共資源实蓬,可以用做流量控制茸俭,譬如數(shù)據(jù)庫連接場景控制等;Semaphore 的構(gòu)造方法 Semaphore(int permits) 接收一個整型參數(shù)安皱,表示可用的許可證數(shù)量调鬓,即最大并發(fā)數(shù)量,使用方法就是在線程里面首先調(diào)用 acquire 方法獲取一個許可练俐,使用完后接著調(diào)用 release 歸還一個許可袖迎,還可以使用 tryAcquire 嘗試獲取許可,其還提供了一些狀態(tài)數(shù)量獲取方法腺晾,不再說明燕锥。
Exchanger:兩個線程進(jìn)行數(shù)據(jù)交換的交換者,其提供一個同步點悯蝉,在這個同步點兩個線程可以交換彼此的數(shù)據(jù)归形,這兩個線程通過 exchange 方法交換數(shù)據(jù),如果第一個線程先執(zhí)行 exchange 方法則它會一直等待第二個線程也執(zhí)行 exchange 方法鼻由,當(dāng)兩個線程都到達(dá)同步點時就可以交換數(shù)據(jù)將本線程生產(chǎn)的數(shù)據(jù)傳遞給對方暇榴;使用場景為并發(fā)校驗等厚棵,可以進(jìn)行 AB 互相 review 保障。