JUC强大的辅助类
JUC強(qiáng)大的輔助類
1.減少計(jì)數(shù)CountDownLatch
2.循環(huán)柵欄CyclicBarrier
3.信號(hào)燈Semaphore
減少計(jì)數(shù)CountDownLatch演示
package juc;
import java.util.concurrent.CountDownLatch;
//演示 CountDownLatch
public class CountDownLatchDemo {
? ? //6個(gè)同學(xué)陸續(xù)離開(kāi)教室之后，班長(zhǎng)鎖門
? ? public static void main(String[] args) throws InterruptedException {
? ? ? ? //創(chuàng)建CountDownLatch對(duì)象，設(shè)置初始值
? ? ? ? CountDownLatch countDownLatch = new CountDownLatch(6);
? ? ? ? //6個(gè)同學(xué)陸續(xù)離開(kāi)教室之后
? ? ? ? for (int i=1; i <=6; i++) {
? ? ? ? ? ? new Thread(()->{
? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+"號(hào)同學(xué)離開(kāi)了教室");
? ? ? ? ? ? ? ? //計(jì)數(shù) -1
? ? ? ? ? ? ? ? countDownLatch.countDown();
? ? ? ? ? ? },String.valueOf(i)).start();
? ? ? ? }
? ? ? ? //等待（變?yōu)?等待結(jié)束）
? ? ? ? countDownLatch.await();
? ? ? ? System.out.println(Thread.currentThread().getName()+"班長(zhǎng)鎖門走人了");
? ? }
}
循環(huán)柵欄CyclicBarrier演示
package juc;
import java.util.concurrent.CyclicBarrier;
//集齊7顆龍珠就可以召喚神龍
public class CyclicBarrierDemo {
? ? //創(chuàng)建固定值
? ? private static final int NUMBER = 7;
? ? public static void main(String[] args) {
? ? ? ? //創(chuàng)建CyclicBarrier
? ? ? ? CyclicBarrier cyclicBarrier = new CyclicBarrier(NUMBER, ()->{
? ? ? ? ? ? System.out.println("集齊7顆龍珠就可以召喚神龍");
? ? ? ? });
? ? ? ? //集齊7顆龍珠過(guò)程
? ? ? ? for (int i=1; i <=7; i++) {
? ? ? ? ? ? new Thread(()->{
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+"龍珠被收集到了");
? ? ? ? ? ? ? ? ? ? //等待
? ? ? ? ? ? ? ? ? ? cyclicBarrier.await();
? ? ? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? },String.valueOf(i)).start();
? ? ? ? }
? ? }
}
信號(hào)燈Semaphore演示
package juc;
import java.util.Random;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
//6輛汽車，停3個(gè)車位
public class SemaphoreDemo {
? ? public static void main(String[] args) {
? ? ? ? //創(chuàng)建Semaphore，設(shè)置許可數(shù)量
? ? ? ? Semaphore Semaphore = new Semaphore(3);
? ? ? ? //模擬6輛汽車
? ? ? ? for (int i=1; i <=6; i++) {
? ? ? ? ? ? new Thread(()->{
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? //搶占
? ? ? ? ? ? ? ? ? ? Semaphore.acquire();
? ? ? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+"搶到了車位");
? ? ? ? ? ? ? ? ? ? //設(shè)置隨機(jī)停車時(shí)間
? ? ? ? ? ? ? ? ? ? TimeUnit.SECONDS.sleep(new Random().nextInt(5));
? ? ? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName()+"離開(kāi)了車位");
? ? ? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? } finally {
? ? ? ? ? ? ? ? ? ? //釋放
? ? ? ? ? ? ? ? ? ? Semaphore.release();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? },String.valueOf(i)).start();
? ? ? ? }
? ? }
}
總結(jié)
- 上一篇： 我从来都不想默默无为，要有所作为就要搞点
- 下一篇： 什么是monitor