基本使用

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;public class ListAdd2 {private volatile static List list = new ArrayList(); public void add(){list.add("cxf");}public int size(){return list.size();}public static void main(String[] args) {final ListAdd2 list2 = new ListAdd2();这个1代表发一次。。如果是2，countDown()执行两次才会通知。final CountDownLatch countDownLatch = new CountDownLatch(1);Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {try {for(int i = 0; i <10; i++){list2.add();System.out.println("当前线程：" + Thread.currentThread().getName() + "添加了一个元素..");Thread.sleep(500);if(list2.size() == 5){System.out.println("已经发出通知..");countDownLatch.countDown();}}                      } catch (InterruptedException e) {e.printStackTrace();}}}, "t1");Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {if(list2.size() != 5){try {countDownLatch.await();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("当前线程：" + Thread.currentThread().getName() + "收到通知线程停止..");throw new RuntimeException();}}, "t2"); t2.start();t1.start();}}

结果

当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
Exception in thread "t2" java.lang.RuntimeExceptionat java.lang.Thread.run(Thread.java:748)
已经发出通知..
当前线程：t1添加了一个元素..
当前线程：t2收到通知线程停止..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..Process finished with exit code 0

总结

new CountDownLatch(1);//这个1代表发一次通知。。如果是2，需要调用countDown()两次才会通知。

java的CountDownLatch使用相关推荐

Java的CountDownLatch和CyclicBarrier的理解和区别
CountDownLatch和CyclicBarrier的功能看起来很相似,不易区分,有一种谜之的神秘.本文将通过通俗的例子并结合代码讲解两者的使用方法和区别. CountDownLatch和Cycl ...
使用Java辅助类(CountDownLatch、CyclicBarrier、Semaphore)并发编程
在java 1.5中,提供了一些非常有用的辅助类来帮助我们进行并发编程,比如CountDownLatch,CyclicBarrier和Semaphore,今天我们就来学习一下这三个辅助类的用法一.C ...
同步机制之--java之CountDownLatch闭锁
CountDownLatch闭锁 1.类介绍一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待.用给定的计数初始化 CountDownLatch.CountDown ...
JAVA多线程-CountDownLatch计数器
一.概述 CountDownLatch是一个同步工具类,它允许一个或多个线程等待其他线程执行完操作之后再继续执行.通常用于控制多个线程的执行顺序. 二.基本原理我们可以把CountDownLatch ...
Java并发——CountDownLatch
CountDownLatch CountDownLatch是Java并发中常用的一个工具类,通常称为锁存器latch,作用为同步一个或多个任务,强制等待指定任务执行完成.即多线程中控制一个或多个线程去 ...
Java中CountDownLatch类
创建CountDownLatch对象时,会传入一个count数值,该对象每次调用countDown()方法会使count -- ,就是count每次减1; 调用await()方法,程序会阻塞等待,当 ...
Java多线程-CountDownLatch用法
CountDownLatch 可以立即看作一个计数器,不过计数是原子操作,也就是说同一时间只有一个线程能够操作该计数器: 我们先看看该类常用的几个方法: 你可以给它设定一个数目,调用该类await方法 ...
Java随笔-CountDownLatch
概述 CountDownLatch其实就是一个计数器,用来同步一个或多个任务,强制任务按步骤执行,多用来协调多线程.也就是一个任务想要执行,必须要等其他任务执行完后才能执行. CountDownLat ...
java异步处理同步化_java 异步查询转同步多种实现方式：循环等待，CountDownLatch，Spring Even...
异步转同步业务需求有些接口查询反馈结果是异步返回的,无法立刻获取查询结果. 正常处理逻辑触发异步操作,然后传递一个唯一标识. 等到异步结果返回,根据传入的唯一标识,匹配此次结果. 如何转换为同步 ...

java的CountDownLatch使用

基本使用

结果

总结

java的CountDownLatch使用相关推荐

最新文章

热门文章