[Java知识库]【JUC】JUC强大的辅助类

减少计数 CountDownLatch

CountDownLatch对象的 await方法是阻塞式的，计数为0才通过。 countDown() 不是阻塞的，会使计数减一

例子： 6个同学离开教室后，班长才可以锁门

public class countDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {

        //创建CountDownLatch对象，设置初始值
        CountDownLatch countDownLatch = new CountDownLatch(6);

        //6个同学陆续离开教室
        for(int i = 1; i <= 6; i++) {
            new Thread(()->{
                countDownLatch.countDown();
                System.out.println(Thread.currentThread().getName() + "号同学离开了教室");
            }, String.valueOf(i)).start();
        }
        countDownLatch.await();
        System.out.println(Thread.currentThread().getName() + "班长锁门走了");
    }
}

循环栅栏CyclicBarrier

例子：及其七颗龙珠即可召唤神龙（继续执行）

public class CyclicBarrierDemo {

    //创建固定在
    private static final int NUMBER = 7;
    public static void main(String[] args) {

        //创建CyclicBarrier, 设定固定值，及达到固定在要做什么
        CyclicBarrier cyclicBarrier = new CyclicBarrier(NUMBER, ()->{
            System.out.println("集齐了七颗龙珠，召唤神龙");
        });

        //集齐7颗龙珠的过程
        for (int i = 1; i <= 7; i++) {
            new Thread(()->{
                try {
                    System.out.println(Thread.currentThread().getName() + "星龙珠被收集到了");
                    cyclicBarrier.await();//没有达到7的时候，不会执行await之后的语句，线程会阻塞，达到7时放行，并执行cyclicBarrier的runnable
                    System.out.println("哈哈哈");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }, String.valueOf(i)).start();
        }
    }
}

信号灯Semaphore

acquire() 方法，从此信号量中获取一个许可，在提供一个许可前线程将一直阻塞
release() 释放一个许可，将其返回给信号量

例子：六辆汽车，停在三个车位

/**
 * 六辆汽车，停在三个停车位
 */
public class SemaphoreDemo {
    public static void main(String[] args) {
        Semaphore semaphore = new Semaphore(3);

        //模拟6辆车
        for (int i = 1; i <= 6; i++) {
            new Thread(() ->{
                try {
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName() + "抢到了停车位");

                    //设置随机停车时间
                    TimeUnit.SECONDS.sleep(new Random().nextInt(5));
                    System.out.println(Thread.currentThread().getName() + "------离开了停车位");

                } catch (Exception e) {
                    e.printStackTrace();
                }finally {
                    semaphore.release();
                }
            }, String.valueOf(i)).start();
        }
    }
}