2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

簡(jiǎn)介

CountDownLatch 允許一個(gè)或多個(gè)線程等待其他線程完成操作。

應(yīng)用場(chǎng)景

假如有這樣一個(gè)需求，當(dāng)我們需要解析一個(gè)Excel里多個(gè)sheet的數(shù)據(jù)時(shí)，可以考慮使用多線程，每個(gè)線程解析一個(gè)sheet里的數(shù)據(jù)，等到所有的sheet都解析完之后，程序需要提示解析完成。在這個(gè)需求中，要實(shí)現(xiàn)主線程等待所有線程完成sheet的解析操作，最簡(jiǎn)單的做法是使用join。代碼如下：

?

public class JoinCountDownLatchTest {public static void main(String[] args) throws InterruptedException {Thread parser1 = new Thread(new Runnable() {@Overridepublic void run() {}});Thread parser2 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("parser2 finish");}});parser1.start();parser2.start();parser1.join();parser2.join();System.out.println("all parser finish");}}

join用于讓當(dāng)前執(zhí)行線程等待join線程執(zhí)行結(jié)束。其實(shí)現(xiàn)原理是不停檢查join線程是否存活，如果join線程存活則讓當(dāng)前線程永遠(yuǎn)wait，代碼片段如下，wait(0)表示永遠(yuǎn)等待下去。

while (isAlive()) {wait(0); }

直到j(luò)oin線程中止后，線程的this.notifyAll會(huì)被調(diào)用，調(diào)用notifyAll是在JVM里實(shí)現(xiàn)的，所以JDK里看不到，有興趣的同學(xué)可以看看JVM源碼。JDK不推薦在線程實(shí)例上使用wait，notify和notifyAll方法。

而在JDK1.5之后的并發(fā)包中提供的CountDownLatch也可以實(shí)現(xiàn)join的這個(gè)功能，并且比join的功能更多。

<pre>public class CountDownLatchTest {static CountDownLatch c = new CountDownLatch(2);public static void main(String[] args) throws InterruptedException {new Thread(new Runnable() {@Overridepublic void run() {System.out.println(1);c.countDown();System.out.println(2);c.countDown();}}).start();c.await();System.out.println("3");}}

CountDownLatch的構(gòu)造函數(shù)接收一個(gè)int類(lèi)型的參數(shù)作為計(jì)數(shù)器，如果你想等待N個(gè)點(diǎn)完成，這里就傳入N。

當(dāng)我們調(diào)用一次CountDownLatch的countDown方法時(shí)，N就會(huì)減1，CountDownLatch的await會(huì)阻塞當(dāng)前線程，直到N變成零。由于countDown方法可以用在任何地方，所以這里說(shuō)的N個(gè)點(diǎn)，可以是N個(gè)線程，也可以是1個(gè)線程里的N個(gè)執(zhí)行步驟。用在多個(gè)線程時(shí)，你只需要把這個(gè)CountDownLatch的引用傳遞到線程里。

其他方法

如果有某個(gè)解析sheet的線程處理的比較慢，我們不可能讓主線程一直等待，所以我們可以使用另外一個(gè)帶指定時(shí)間的await方法，await(long time, TimeUnit unit): 這個(gè)方法等待特定時(shí)間后，就會(huì)不再阻塞當(dāng)前線程。join也有類(lèi)似的方法。

注意：計(jì)數(shù)器必須大于等于0，只是等于0時(shí)候，計(jì)數(shù)器就是零，調(diào)用await方法時(shí)不會(huì)阻塞當(dāng)前線程。CountDownLatch不可能重新初始化或者修改CountDownLatch對(duì)象的內(nèi)部計(jì)數(shù)器的值。一個(gè)線程調(diào)用countDown方法 happen-before 另外一個(gè)線程調(diào)用await方法。

?

擴(kuò)展閱讀：http://www.infoq.com/cn/articles/java8-abstractqueuedsynchronizer

轉(zhuǎn)載于:https://my.oschina.net/viakiba/blog/1456754

總結(jié)

以上是生活随笔為你收集整理的等待多线程完成的CountDownLatch的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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