资讯专栏INFORMATION COLUMN

Java多线程同步工具箱之CountDownLatch篇

lufficc / 864人阅读

摘要:多线程同步工具箱之篇前言的多线程协调工具,,,都是在多线程代码中使用比较多的工具类之一。毫不夸张的说,这几个类,是等同于解决多线程问的包,实在有必要添加到程序员的工具箱里面。

Java多线程同步工具箱之CountDownLatch篇 前言

Java的多线程协调工具CountDownLatch,Semaphore,CyclicBarrier,ReadWriteLock都是在多线程代码中使用比较多的工具类之一。掌握及理解这几个类的实现,对解决和理解多线程中复杂的业务状况有很重要的作用。毫不夸张的说,这几个类,是等同于解决多线程问的java.util包,实在有必要添加到程序员的工具箱里面。

此次文章,将分几篇总结及解读一下这些工具类的具体用法和范例,最后,希望可以再深入一点去理解这几个多线程工具的实现。

1. CountDownLatch(倒数锁)

CountDownLatch是一个常用的多线程协调工具:主要为协调一个或多个线程完成后,主线程进行某个操作的功能。

Latch原指门闩,CountDownLatch译为倒数锁倒是不太过分。可以理解为:使用主线程初始化一个有N个子锁的锁,任务开始的时,分配给N个线程每个线程持有一把钥匙,每个线程到某个状态后(一般为完成),可以使用线程持有的钥匙打开主线程持有的锁,直至所有N个锁都被打开,主线程才可以继续其他任务。

1.1 API

从API上看我们可以关注下面几个CountDownLatch提供了几个接口:

构造方法CountDownLatch(int)

构造方法十分简单,注入一个int,初始化倒数锁的大小。

await()

等待所有锁被解开,该函数还有一个带等待时长及等待时间单位的重写await(long time, TimeUnit unit),用于避免过度的等待造成的死锁。

countDown()

解锁方法,解开一个锁,知道持有的锁数量为0,则接触await的状态。

getCount()

获取当前的剩余的锁的数量。

1.2 范例

在范例中,我们简单的使用一个主线程,发起若干个子线程,让子线程进行休眠的例子作为测试倒数,让各个子线程导数完通知解锁,主线程会被在所有子线程完成解锁后通知所有任务完成。

1.2.1 使用倒数锁前
App.java

import java.util.concurrent.CountDownLatch;
import java.util.logging.Logger;

public class App {

    static Logger log = Logger.getAnonymousLogger();

    public static void main(String[] args) {
        
        for (int index = 0; index < 10; index++) {
            new Thread(new SubThread(index, index)).start();
        }

        // 所有的线程都完成了
        log.info("all thread finished");
    }

}
SubThread.java

import java.util.concurrent.CountDownLatch;
import java.util.logging.Logger;

public class SubThread implements Runnable {

    private int id;
    private int waitSecond;

    static Logger log = Logger.getAnonymousLogger();

    public SubThread(int id, int waitSecond) {
        this.id = id;
        // 秒数*1000毫秒 = 实际等待毫秒数
        this.waitSecond = waitSecond * 1000;
    }

    public void run() {
        try {
            log.info("Thread " + id + " started.");
            // 让Thread再飞一会儿
            Thread.sleep(waitSecond);

            log.info("Thread " + id + " end.");
            // 通知完成
        } catch (InterruptedException e) {
            log.config("error");
        }
    }

}
运行结果

可以从结果中看到,所有的线程启动后,主线程就会立刻退出,子线程会在完成各自的任务后再退出。

Aug 09, 2018 6:43:22 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 3 started.

...
...

Aug 09, 2018 6:43:22 PM online.tangbk.demo.thead.App main
INFO: all thread finished
Aug 09, 2018 6:43:22 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 8 started.

...
...

Aug 09, 2018 6:43:31 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 9 end.
1.2.2 使用倒数锁后
App.java

import java.util.concurrent.CountDownLatch;
import java.util.logging.Logger;

public class App {

    static Logger log = Logger.getAnonymousLogger();

    public static void main(String[] args) {

        // 初始化10个线程的锁
        CountDownLatch cdl = new CountDownLatch(10);

        for (int index = 0; index < 10; index++) {
            // 将锁传给子线程
            new Thread(new SubThread(index, index, cdl)).start();
        }

        try {
            // 等待所有的锁被(倒数)释放
            cdl.await();
        } catch (InterruptedException e) {

            e.printStackTrace();
        }
        // 所有的线程都完成了
        log.info("all thread finished");
    }

}
SubThread.java

import java.util.concurrent.CountDownLatch;
import java.util.logging.Logger;

public class SubThread implements Runnable {

    private int id;
    private int waitSecond;
    private CountDownLatch cdl;

    static Logger log = Logger.getAnonymousLogger();

    public SubThread(int id, int waitSecond, CountDownLatch cdl) {
        this.id = id;
        // 秒数*1000毫秒 = 实际等待毫秒数
        this.waitSecond = waitSecond * 1000;
        this.cdl = cdl;
    }

    public void run() {
        try {
            log.info("Thread " + id + " started.");
            // 让Thread再飞一会儿
            Thread.sleep(waitSecond);

            cdl.countDown();
            log.info("Thread " + id + " end.");
            // 通知完成
        } catch (InterruptedException e) {
            log.config("error");
        }
    }

}
运行结果

可以从结果中看到,所有的线程启动后,都会等到所有线程完成等待后才结束。

Aug 09, 2018 6:29:20 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 2 started.
Aug 09, 2018 6:29:20 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 3 started.
Aug 09, 2018 6:29:20 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 1 started.
Aug 09, 2018 6:29:20 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 0 started.

...
...

Aug 09, 2018 6:29:28 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 8 end.
Aug 09, 2018 6:29:29 PM online.tangbk.demo.thead.SubThread run
INFO: Thread 9 end.
Aug 09, 2018 6:29:29 PM online.tangbk.demo.thead.App main
INFO: all thread finished
1.3 CountDownLatch小结

CountDownLatch(倒数锁)适用于需要等待子线程完成后,统一进行操作的一些操作。更可以结合FutureTask的相关接口,取回子线程的结果,对结果统一搜集处理。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/76682.html

相关文章

  • Java线程打辅助的三个小伙子

    摘要:前言之前学多线程的时候没有学习线程的同步工具类辅助类。而其它线程完成自己的操作后,调用使计数器减。信号量控制一组线程同时执行。 前言 之前学多线程的时候没有学习线程的同步工具类(辅助类)。ps:当时觉得暂时用不上,认为是挺高深的知识点就没去管了.. 在前几天,朋友发了一篇比较好的Semaphore文章过来,然后在浏览博客的时候又发现面试还会考,那还是挺重要的知识点。于是花了点时间去了解...

    pingink 评论0 收藏0
  • Java线程进阶(九)—— J.U.Clocks框架:AQS共享功能剖析(4)

    摘要:好了,继续向下执行,尝试获取锁失败后,会调用首先通过方法,将包装成共享结点,插入等待队列,插入完成后队列结构如下然后会进入自旋操作,先尝试获取一次锁,显然此时是获取失败的主线程还未调用,同步状态还是。 showImg(https://segmentfault.com/img/remote/1460000016012541); 本文首发于一世流云的专栏:https://segmentfa...

    CompileYouth 评论0 收藏0
  • Java同步机制的底层实现

    摘要:在多线程编程中我们会遇到很多需要使用线程同步机制去解决的并发问题,而这些同步机制就是多线程编程中影响正确性和运行效率的重中之重。这五个方法之所以能指定同步器的行为,则是因为中的其他方法就是通过对这五个方法的调用来实现的。 在多线程编程中我们会遇到很多需要使用线程同步机制去解决的并发问题,而这些同步机制就是多线程编程中影响正确性和运行效率的重中之重。这不禁让我感到好奇,这些同步机制是如何...

    yintaolaowanzi 评论0 收藏0
  • 死磕 java同步系列volatile解析

    摘要:前半句是指线程内表现为串行的语义,后半句是指指令重排序现象和工作内存和主内存同步延迟现象。关于内存模型的讲解请参考死磕同步系列之。目前国内市面上的关于内存屏障的讲解基本不会超过这三篇文章,包括相关书籍中的介绍。问题 (1)volatile是如何保证可见性的? (2)volatile是如何禁止重排序的? (3)volatile的实现原理? (4)volatile的缺陷? 简介 volatile...

    番茄西红柿 评论0 收藏0

发表评论

0条评论

lufficc

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<