一、CountDownLatch

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

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

常用方法：

????????

countDownLatch.countDown() // 相當于-1操作 ountDownLatch.await(); //等待計數(shù)器歸零，然后向下執(zhí)行 public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {//有必須要執(zhí)行的任務(wù)的時候再使用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(); //等待計數(shù)器歸零，然后向下執(zhí)行System.out.println("某行為");} }

二、CyclicBarrier ?

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

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

CyclicBarrier cyclicBarrier = new CyclicBarrier(5,()->{}); public class CyclicBarrierDemo {public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(5,()->{System.out.println("進度條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

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

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

場景：搶車位? 6輛車三個車位?

public class SemaphoreDemo {public static void main(String[] args) {//參數(shù)：線程數(shù)量 --- > 停車位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é)

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

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