跳至主要內容

CountDownLatch的使用

DHB大约 1 分钟Java线程

CountDownLatch的使用

实现一个容器,提供get和size两个方法,些两个线程,线程1添加10个元素到容器中,线程2实现监控元素的个数,当个数大于5时,线程2给出提示并结束

接着这个问题,上一篇笔记的实现方法是用synchronized、wait和notify实现的,这种实现方式比较重,当不涉及同步,只是涉及线程通信的时候,那有没有更好的实现方法呢?(这不是废话吗)

CountDownLatch

CountDownLatch是一个非常实用的多线程控制的工具。常用的几个方法:

//实例化一个倒数器,count是指定计数个数
CountDownLatch(int count)
// 当count不等于0时,一直阻塞
void await()
// count - 1  操作
void countDown()

接下来用CountDownLatch来完成上面的题目

代码

public class Container2 {

    /**
     * 容器,volatile保证可见性
     */
    volatile List<Object> list = new ArrayList<>();

    /**
     * 添加元素方法
     *
     * @param object obj
     */
    public void add(Object object) {
        list.add(object);
    }

    /**
     * 返回容器大小
     *
     * @return 容器大小
     */
    public int size() {
        return list.size();
    }


    private static CountDownLatch countDownLatch = new CountDownLatch(1);

    public static void main(String[] args) {
        Container2 container1 = new Container2();

        new Thread(() -> {
            if (container1.size() != 5) {
                try {
                    countDownLatch.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("容器到达5个,结束");
            }
        }).start();

        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                System.out.println(Thread.currentThread().getName() + "---" + i);
                try {
                    TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                container1.add(new Object());
                if (container1.size() == 5) {
                    countDownLatch.countDown();
                }
            }
        }).start();
    }
}
上次编辑于:
贡献者: dhb,donghaibin