文章目錄

• 信號量(Semaphore)
• 屏障（CycliBarrier）
• 倒計時器(CountDownlatch)

---

信號量(Semaphore)

信號量控制一起進入線程的數量,通俗點講是 synchronized 的加強版，作用是控制線程的并發數量

搶車位！

6個車 – 3個停車位

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

semaphore.acquire(); 獲得，如果已經滿了就等待被釋放為止！

semaphore.release(); 釋放，會將當前的信號量釋放 + 1， 然后喚醒等待的線程！

作用：多個共享資源互斥的使用，并發限流，控制最大的線程數

屏障（CycliBarrier）

一組線程彼此互相等待

import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier;public class CycliBarrierDemo {public static void main(String[] args) {// 集齊7顆龍珠召喚神龍//召喚龍珠線程CyclicBarrier cyclicBarrier = new CyclicBarrier(7, ()->{System.out.println("召喚神龍成功！");});for (int i = 1; i <= 7; i++) {final int temp = i;new Thread(() -> {System.out.println(Thread.currentThread().getName() + "收集" + temp + "顆龍珠");try {//等待7個線程執行完畢cyclicBarrier.await();System.out.println("abc");} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }

倒計時器(CountDownlatch)

一個任務等待一組任務，結束后，被喚醒的功能
注意：直到由于 countDown() 方法的調用而導致當前計數達到零，之后所有等待線程被釋放，并且任何后續的await 調用立即返回。 這是一個一次性的現象 - 計數無法重置。

import java.util.concurrent.CountDownLatch;//計數器 public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {//總數是6，必須要執行任務的時候，再使用！CountDownLatch countDownLatch = new CountDownLatch(6);for (int i = 1; i <= 6; i++) {new Thread(() -> {System.out.println(Thread.currentThread().getName() + " Go out");//數量-1countDownLatch.countDown();}, String.valueOf(i)).start();}//等待計數器歸0 然后再向下執行countDownLatch.await();System.out.println("Close Door");} }

總結

以上是生活随笔為你收集整理的并发编程-Semaphore,CycliBarrier,CountDownlatch类的使用的全部內容，希望文章能夠幫你解決所遇到的問題。

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