文章目錄

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

---

信號量(Semaphore)

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

搶車位！

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(); 獲得，如果已經(jīng)滿了就等待被釋放為止！

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

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

屏障（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個線程執(zhí)行完畢cyclicBarrier.await();System.out.println("abc");} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }

倒計時器(CountDownlatch)

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

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

總結

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

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