并发常用辅助类
一、CountDownLatch
CountDownLatch是一個減法計數(shù)器,允許一個或多個線程等直到在其他線程中執(zhí)行的一組操作完成的同輔助。
????????每次有線程調(diào)用countDown()時數(shù)量 -1 ,countDownLatch.await()就會被喚醒,繼續(xù)執(zhí)行
常用方法:
????????
countDownLatch.countDown() // 相當于-1操作 ountDownLatch.await(); //等待計數(shù)器歸零,然后向下執(zhí)行 public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {//有必須要執(zhí)行的任務(wù)的時候再使用CountDownLatch countDownLatch = new CountDownLatch(5);//countDownLatch.countDown(); // -1for (int i = 1; i <= 5; i++) {new Thread(()->{countDownLatch.countDown();System.out.println(Thread.currentThread().getName()+"Go!");},String.valueOf(i)).start();}countDownLatch.await(); //等待計數(shù)器歸零,然后向下執(zhí)行System.out.println("某行為");} }二、CyclicBarrier ?
? ? ? ? CyclicBarrier是一個加法計數(shù)器,允許一組線程全部等待彼此達到共同屏障點的同步輔助。
? ? ? ? 在new一個CyclicBarrier對象時,參數(shù)可以傳一個int型,也可以傳一個int型加一個Runnable接口。
CyclicBarrier cyclicBarrier = new CyclicBarrier(5,()->{}); public class CyclicBarrierDemo {public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(5,()->{System.out.println("進度條100%");});for (int i = 1; i <= 5; i++) {final int temp = i;//lambda不能拿到inew Thread(()->{System.out.println(Thread.currentThread().getName()+"Loading..."+temp);try {cyclicBarrier.await();//等待} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }?
三、Semaphore
?作用:多個共享資源的互斥使用;限流
//參數(shù)填默認線程數(shù)量 Semaphore semaphore = new Semaphore(5); //獲得,如果信號量已經(jīng)滿了,等待被釋放為止 semaphore.acquire(); //釋放,將當前的信號量釋放,喚醒等待的線程 semaphore.release();場景:搶車位? 6輛車三個車位?
public class SemaphoreDemo {public static void main(String[] args) {//參數(shù):線程數(shù)量 --- > 停車位Semaphore semaphore = new Semaphore(3);for (int i = 1; i <= 6; i++) {new Thread(()->{try {semaphore.acquire();System.out.println(Thread.currentThread().getName()+"Park!");TimeUnit.SECONDS.sleep(2);System.out.println(Thread.currentThread().getName()+"Leave!");} catch (InterruptedException e) {}finally {semaphore.release();}},String.valueOf(i)).start();}} }?
總結(jié)
- 上一篇: windows批量修改文件权限
- 下一篇: JUC的常用辅助工具