1.減計數器-CountDownLatch

• 允許一個或多個線程等待直到在其他線程中執行的一組操作完成的同步輔助。

public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {//定義：允許一個或多個線程等待直到在其他線程中執行的一組操作完成的同步輔助。//用途：1.一個CountDownLatch為一個計數的CountDownLatch用作一個簡單的開/關鎖存器，或者門：// 所有線程調用await在門口等待，直到被調用countDown()的線程打開。// 2.一個CountDownLatch初始化N可以用來做一個線程等待，直到N個線程完成某項操作，或某些動作已經完成N次CountDownLatch countDownLatch = new CountDownLatch(20);for (int i=1 ;i<=20;i++){// new Thread(()->{countDownLatch.countDown();System.out.println(Thread.currentThread().getName()+">="+countDownLatch.getCount());//},String.valueOf(i)).start();}//特性：它不要求調用countDown線程等待計數到達零之前繼續，// 它只是阻止任何線程通過await ，直到所有線程可以通過。System.out.println("我可以在Await方法之前執行");countDownLatch.await();System.out.println("我為什么在最后執行呢");} }

2.加計數器-CyclicBarrier

• 等待多個操作完成，再執行下一步

public class CyclicBarrierDemo {public static void main(String[] args) throws BrokenBarrierException, InterruptedException {//適用需等待多個操作完成，再執行下一步CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{System.out.println("舍利子集齊成功，如來重生");});for (int i=1;i<=7;i++){int finalI = i;new Thread(()->{System.out.println(Thread.currentThread().getName()+"：收集了"+ finalI +"顆");try {//等待，舍利子集齊，一起向下執行cyclicBarrier.await();System.out.println("無天必須在如來重生之后，再死");} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}} }

3.Semaphore

• 限流
• 多個資源的互斥使用

public class SemaphoreDemo {public static void main(String[] args) {//限流：停車位為3，車位滿之后，等待車走，再進一個。//多個資源的互斥使用Semaphore semaphore = new Semaphore(3);for (int i=1;i<=6;i++){new Thread(() -> {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();}},String.valueOf(i)).start();}}}

總結

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

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