日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

常用的辅助类

發布時間:2023/12/18 编程问答 27 豆豆
生活随笔 收集整理的這篇文章主要介紹了 常用的辅助类 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

常用的輔助類

一、CountDownLath

//計數器 public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {// 倒計時總數是6, 必須要執行任務的時候,再使用!CountDownLatch countDownLatch = new CountDownLatch(6);for (int i = 0; i < 6; i++) {new Thread(()->{System.out.println(Thread.currentThread().getName() + " GO out");countDownLatch.countDown(); //數量減1},String.valueOf(i)).start();}countDownLatch.await();// 等待計數器歸零,喚醒該線程,然后再向下執行System.out.println("close Door");} }

原理:

? countDownLatch.countDown(); 數量-1

? countDownLatch.await(); 等待計數器歸0,再向下執行

? 每次有線程調用countDown()數量-1,假設計數器變為0 , countDownLatch.await()就會被喚醒,繼續執行!

二、CyclicBarrier

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

加法計數器

import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier;public class CyclicBarrierDemo {public static void main(String[] args) {/** 集齊7可龍珠召喚神龍* 召喚龍珠的線程* */CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{System.out.println("召喚神龍成功");});for (int i = 1; i <= 7; i++) {int temp = i;// lambda 能操作到i么? 本質不能,需要final修飾int temp// 但是jdk1.8之后有優化,new Thread(()->{System.out.println(Thread.currentThread().getName()+"收集"+temp+"個龍珠");try {cyclicBarrier.await(); // 等待} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }

三、Semaphore

Semaphore:信號量

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

原理:

semaphore.acquire():獲得,假設如果已經滿了,等待,等待被釋放為止!
semaphore.release():釋放,會將當前的信號量釋放+1,然后喚醒等待的線程!

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

總結

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

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