Java.utils.concurrent包中的幾個(gè)有用的類（CountDownLatch、CyclicBarrier、Semaphore）

2019-11-06 07:34:12

字體：大中小

供稿：網(wǎng)友

CountDownLatch

它是一個(gè)計(jì)數(shù)器，類中有兩個(gè)重要的方法：countDown(),await() .new的時(shí)候需要用一個(gè)整數(shù)參數(shù) 。設(shè)置線程計(jì)數(shù)的數(shù)量。然后在每個(gè)線程中會調(diào)用countDown方法（就是計(jì)數(shù)器減一）。之后我們可以調(diào)用await方法等待所有的線程都結(jié)束后才去執(zhí)行后面的任務(wù)。

CyclicBarrier

設(shè)置線程阻塞。其構(gòu)造函數(shù)可以接受一個(gè)數(shù)或者一個(gè)數(shù)和一個(gè)Runnable實(shí)例。即可以設(shè)置屏障的數(shù)量和屏障數(shù)量達(dá)到后需要執(zhí)行的線程。在每個(gè)線程里面會調(diào)用await方法，讓當(dāng)前線程在這個(gè)地方阻塞起來，知道屏障數(shù)達(dá)到設(shè)定值的時(shí)候所以的線程才開始運(yùn)行（即執(zhí)行上面構(gòu)造函數(shù)傳入的Runnable實(shí)例的run方法）。

Semapphore

用來控制流量的。其構(gòu)造函數(shù)接受一個(gè)數(shù)字。類中兩個(gè)有用的方法acquire，release 。在線程執(zhí)行前首先會申請一個(gè)許可證也就是調(diào)用acquire方法，線程結(jié)束的時(shí)候就會歸還許可證也就是調(diào)用release 。當(dāng)外界對一個(gè)應(yīng)用沒有一個(gè)流量概念的時(shí)候，很有可能超過其能承受的負(fù)載，所以我們可以在其中加入Semappore控制，技術(shù)外面創(chuàng)建了更多的線程，其實(shí)也只能有限制的那么多線程能同時(shí)執(zhí)行。

上一篇：java之成績總結(jié)

下一篇：Java 給飛秋發(fā)送消息