一、CountDownLatch

CountDownLatch是一個(gè)減法計(jì)數(shù)器，允許一個(gè)或多個(gè)線程等直到在其他線程中執(zhí)行的一組操作完成的同輔助。

????????每次有線程調(diào)用countDown()時(shí)數(shù)量 -1 ，countDownLatch.await()就會(huì)被喚醒，繼續(xù)執(zhí)行

常用方法：

????????

countDownLatch.countDown() // 相當(dāng)于-1操作 ountDownLatch.await(); //等待計(jì)數(shù)器歸零，然后向下執(zhí)行 public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {//有必須要執(zhí)行的任務(wù)的時(shí)候再使用CountDownLatch countDownLatch = new CountDownLatch(5);//countDownLatch.countDown(); // -1for (int i = 1; i <= 5; i++) {new Thread(()->{countDownLatch.countDown();System.out.println(Thread.currentThread().getName()+"Go!");},String.valueOf(i)).start();}countDownLatch.await(); //等待計(jì)數(shù)器歸零，然后向下執(zhí)行System.out.println("某行為");} }

二、CyclicBarrier ?

? ? ? ? CyclicBarrier是一個(gè)加法計(jì)數(shù)器，允許一組線程全部等待彼此達(dá)到共同屏障點(diǎn)的同步輔助。

? ? ? ? 在new一個(gè)CyclicBarrier對(duì)象時(shí)，參數(shù)可以傳一個(gè)int型，也可以傳一個(gè)int型加一個(gè)Runnable接口。

CyclicBarrier cyclicBarrier = new CyclicBarrier(5,()->{}); public class CyclicBarrierDemo {public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(5,()->{System.out.println("進(jìn)度條100%");});for (int i = 1; i <= 5; i++) {final int temp = i;//lambda不能拿到inew Thread(()->{System.out.println(Thread.currentThread().getName()+"Loading..."+temp);try {cyclicBarrier.await();//等待} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }

?

三、Semaphore

?作用：多個(gè)共享資源的互斥使用；限流

//參數(shù)填默認(rèn)線程數(shù)量 Semaphore semaphore = new Semaphore(5); //獲得，如果信號(hào)量已經(jīng)滿(mǎn)了，等待被釋放為止 semaphore.acquire(); //釋放，將當(dāng)前的信號(hào)量釋放，喚醒等待的線程 semaphore.release();

場(chǎng)景：搶車(chē)位? 6輛車(chē)三個(gè)車(chē)位?

public class SemaphoreDemo {public static void main(String[] args) {//參數(shù)：線程數(shù)量 --- > 停車(chē)位Semaphore semaphore = new Semaphore(3);for (int i = 1; i <= 6; i++) {new Thread(()->{try {semaphore.acquire();System.out.println(Thread.currentThread().getName()+"Park!");TimeUnit.SECONDS.sleep(2);System.out.println(Thread.currentThread().getName()+"Leave!");} catch (InterruptedException e) {}finally {semaphore.release();}},String.valueOf(i)).start();}} }

?

總結(jié)

以上是生活随笔為你收集整理的并发常用辅助类的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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