package com.huangbei.test2;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.CountDownLatch;

import static com.huangbei.util.Sleeper.sleep;

@Slf4j(topic = "c.Test-CountdownLatch")
public class Test22 {

    public static void main(String[] args) {
        CountDownLatch latch = new CountDownLatch(3);
        new Thread(() -> {
            try {
                log.debug("开始等待.....");
                latch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            log.debug("恢复运行");
        },"等待线程").start();

        sleep(0.5);
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                log.debug("执行任务...");
                latch.countDown();
            }).start();
            sleep(1);
        }


    }
}