CountDownLatch（減法計數器）

計數器

具體使用，只有計數器歸零了主線程才能繼續向下執行（即計數器歸零后，await（）才會被喚醒）

public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {CountDownLatch countDownLatch = new CountDownLatch(6);for (int i = 0; i < 6 ; i++) {new Thread(() -> {System.out.println("第" + Thread.currentThread().getName() + "人出門了") ;countDownLatch.countDown(); //數量-1}, String.valueOf(i + 1)).start();}countDownLatch.await(); //等待計數器歸零，才會繼續執行下去System.out.println("門關上了");} }

CyclicBarrier（加法計數器）

加法計數器代碼

public class CyclicBarrierDemo {public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(7, () -> {System.out.println("召喚神龍成功");});for (int i = 0; i < 7; i++) {new Thread(() -> {System.out.println("收集了" + Thread.currentThread().getName() + "顆龍珠");try {cyclicBarrier.await();} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}, String.valueOf(i +1)).start();}}}

只有當七個線程中的await都執行到了才會執行cyclicBarrier的第二個參數方法，該類兩個構造方法

Semaphore

Semaphore:信號量，限流使用

具體實現，搶車位，三個車位6輛車

public class SemaphoreDemo {public static void main(String[] args) {Semaphore semaphore = new Semaphore(3);for (int i = 0; i < 6; i++) {new Thread(() -> {try {semaphore.acquire(); //得到System.out.println(Thread.currentThread().getName() + "搶到了車位");TimeUnit.SECONDS.sleep(1);System.out.println(Thread.currentThread().getName() + "離開了車位");} catch (InterruptedException e) {e.printStackTrace();} finally {semaphore.release(); //釋放}}, String.valueOf(i + 1)).start();}} }

原理：
semaphore.acire() 獲得，假設如果已經滿了則等待，等待到釋放為止
semaphore.release()釋放，會將當前的信號量釋放+1，然后喚醒等待的線程！
作用：多個共享資源互斥的使用！并發限流，控制最大的線程數！

總結

以上是生活随笔為你收集整理的JUC学习笔记（二）——常用的辅助类的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。