星驰编程网

免费编程资源分享平台_编程教程_代码示例_开发技术文章

CountDownLatch简单使用(countdownlatch的await)

CountDownLatch简单使用

  • 描述:CountDownLatch允许一个或多个线程等待直到在其他线程中执行的一组操作完成的同步辅助。
  • 用法: 多个人等一个信号后继续执行操作。例如一共需要6个人在车上才能开车。
    public static void main(String[] args) throws InterruptedException {
        // 减法计数器,总数是6
        CountDownLatch countDownLatch = new CountDownLatch(6);

        for (int i = 1; i <= 6; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + "上车了");
                countDownLatch.countDown();// -1
            }, "第"+String.valueOf(i)+"个人").start();
        }

        countDownLatch.await();// 等待所有人都上车了,才开车
        System.out.println("上车完成,开车!");

    }
  • 如果只有5个人上车了,不够6个人,会一直等待。
  • 如果不够6个人,也可以开车出发,可以使用await(long timeout, TimeUnit unit) ,表示
    使当前线程等待直到锁存器计数到零为止,除非线程为 interrupted或指定的等待时间过去。
public static void main(String[] args) throws InterruptedException {
        // 减法计数器,总数是6
        CountDownLatch countDownLatch = new CountDownLatch(6);

        for (int i = 1; i <= 4; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + "上车了");
                countDownLatch.countDown();// -1
            }, "第"+String.valueOf(i)+"个人").start();
        }

        countDownLatch.await(5,TimeUnit.SECONDS);// 等5秒之后,如果没有人上车了,就开车
        System.out.println("还差"+countDownLatch.getCount()+"人就满了,不等了,开车!");

      
    }
控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言