CountDownLatch 计数器

public class CountdownlachTest {
    public static void main(String[] args) {
        /** 先开个玩具厂 */
        ToyFactory factory = new ToyFactory();
        /** 玩具厂生产玩具咯，先来50个玩具 */
        int toyNum = factory.produceToy(50);
        System.err.println(toyNum + "个玩具新鲜出炉");
        CountDownLatch countDownLatch = new CountDownLatch(toyNum);
        /** 叫销售员去卖吧 */
        ToySalesperson zhangsan = new ToySalesperson("张三",12,factory,countDownLatch);
        ToySalesperson lisi = new ToySalesperson("李四",12,factory,countDownLatch);
        ToySalesperson wangwu = new ToySalesperson("王五",10,factory,countDownLatch);
        ToySalesperson zhaoliu = new ToySalesperson("赵六",16,factory,countDownLatch);
        /** 销售员干活吧 */
        zhangsan.start();
        lisi.start();
        wangwu.start();
        zhaoliu.start();
        /** 继续产玩具 */
        int produceToy = factory.produceToy(100);
        if(produceToy <= 0) {
            /** 还有玩具不给我生产，那我关厂等呗 */
            try {
                countDownLatch.await();
            } catch (InterruptedException e) {
                System.err.println("玩具厂----暂停营业呢，你们来吵我干嘛");
            }
        }
        if(factory.toyNum <= 0) {
            /** 玩具卖完了，继续开工吧 */
            System.err.println("玩具厂----我又复活了，大量招工");
        }
    }
}

/**
 *     玩具工厂
 * */
class ToyFactory{
    Integer toyNum = 0;        // 玩具数量
    /** 生产玩具 */
    public int produceToy(int num) {
        if(toyNum > 0) {
            System.err.println("厂里还有玩具，必须先卖完，不能堆积");
            return 0;
        }
        this.toyNum = num;
        return this.toyNum;
    }
}
/**
 *     销售员
 * */
class ToySalesperson extends Thread{
    String name;    // 线程名
    int myToyNum;    // 我的任务量
    CountDownLatch countDownLatch;    // 剩余总量
    ToyFactory factory;
    public ToySalesperson(String name,int myToyNum,ToyFactory factory,CountDownLatch countDownLatch) {
        super(name);
        this.name = name;
        this.myToyNum = myToyNum;
        this.countDownLatch = countDownLatch;
        this.factory = factory;
    }
    @Override
    public void run() {
        /** 不断卖玩具 */
        while(true) {
            if(myToyNum <= 0) {
                System.err.println(name + "----" + "我的任务完成了，玩具卖完了，老子不用再加班了！！！");
                return;
            }
            try {
                /** 模拟到处跑卖玩具 */
                TimeUnit.SECONDS.sleep(2);
                System.err.println(name + "----" + "终于卖出一个了，真艰难啊，还剩" + myToyNum + "个");
                myToyNum--;
                countDownLatch.countDown();
                synchronized (factory.toyNum) {
                    factory.toyNum--;
                }
            } catch (InterruptedException e) {
                /** 线程被中断 */
                System.err.println(name + "----" + "老板给我穿小鞋，老子不干啦");
                return;
            }
        }
    }
}