6.1 CountDownLatch

6.1.1 基本概念

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-Qp6uFu8K-1614138326808)(https://guardwhy.oss-cn-beijing.aliyuncs.com/img/javaSE/se2/33-javase.png)]

6.1.2 底層源碼

6.1.3 代碼示例

package cn.guardwhy.juc01;import java.util.concurrent.CountDownLatch;public class CountDownLatchDemo01 {public static void main(String[] args) throws InterruptedException {// 1.創建countDownLatch對象CountDownLatch countDownLatch = new CountDownLatch(6);for (int i = 0; i <=6 ; i++) {new Thread(()->{System.out.println(Thread.currentThread().getName() + " Start");// 數量-1countDownLatch.countDown();}, String.valueOf(i)).start();}// 等待計數器歸零，然后再往下執行。countDownLatch.await();System.out.println("End..");} }

原理分析

CountDownLatch 主要有兩個方法，當一個或多個線程調用 await 方法時，這些線程會阻塞其他線程調用CountDown方法會將計數器減1(調用CountDown方法的線程不會阻塞）當計數器變為0時，await 方法阻塞的線程會被喚醒，繼續執行。

6.2 CyclicBarrier

6.2.1 基本概念

加法計數器

6.2.2 代碼示例

package cn.guardwhy.juc01;import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier;public class CyclicBarrierDemo01 {public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{System.out.println("NBA王朝成立");});for (int i = 0; i <=7 ; i++) {int temp = i;new Thread(()->{System.out.println(Thread.currentThread().getName() + "拿到" + temp + "個總冠軍");try {// 等待操作cyclicBarrier.await();} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }

6.3 Semaphore

6.3.1 基本概念

信號量;信號燈;信號

6.3.2 代碼示例

package cn.guardwhy.juc01;import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit;public class SemaphoreDemo01 {public static void main(String[] args) {// 線程數量Semaphore semaphore = new Semaphore(3);// 多線程for (int i = 0; i <=5 ; i++) {new Thread(()->{try {// acquire() 得到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();}}).start();}} }

6.3.3 原理分析

CyclicBarrier：指定個數線程執行完畢再執行操作。

semaphore：同一時間只能有指定數量個得到線程。

在信號量上兩種操作

acquire（獲取）

• 當一個線程調用 acquire 操作時，他要么通過成功獲取信號量（信號量-1）
• 要么一直等下去，直到有線程釋放信號量，或超時。

release （釋放）

• 實際上會將信號量的值 + 1，然后喚醒等待的線程。
• 信號量主要用于兩個目的：一個是用于多個共享資源的互斥使用，另一個用于并發線程數的控制。

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

總結

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

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