线程-CountDownLatch的使用

痛定思痛。 2021-09-24 03:04 282阅读 0赞

### CountDownLatch的使用 ###

*   *  CountDownLatch

> 遇到此问题的环境：我需要从数据库中取出5000条数据，循环数据，对**每条数据每个字段**进行分析处理，这里每个字段都会创建**新的线程**去处理，并写库；只有当每个线程执行完，才能进行下一次的循环。

## CountDownLatch ##

*  countDownLatch这个类使一个线程等待其他线程各自执行完毕后再执行。
 *  是通过一个计数器来实现的，计数器的初始值是线程的数量。每当一个线程执行完毕后，计数器的值就-1，当计数器的值为0时，表示所有线程都执行完毕，然后在闭锁上等待的线程就可以恢复工作了。

private ExecutorService pool = null;
    private static int zdNum = 16;// 字段数
    public void run() { 
    	// 创建线程池
    	pool = Executors.newFixedThreadPool(zdNum);
    	// 定义计数器
    	final CountDownLatch latch = new CountDownLatch(zdNum);
    	// 获取5000条数据
    	List list = getData();
    	for(int i=1;i<=list.size();i++){ 
    		final int j = i;	// 多线程中for循环变量需要拿出来定义
    		pool.execute(new Runnable() { 
    			@Override
    			public void run() { 
    				try{ 
    					switch(j) { 
    					case 1:
    					case 2:
    					...
    					//分需求处理
    					}
    				}catch (Exception e) { 
    					e.printStackTrace();
    				} finally { 
    					latch.countDown();// 每个线程执行完，计数器-1 如果>0则会执行await方法阻塞线程。
    				}
    			}
    		});
    	}
    	latch.await();//阻塞当前线程，直到计数器的值为0 ，所以会等这次循环走完才会执行下一次循环。
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，282人围观）

还没有评论，来说两句吧...

相关阅读

相关多线程（27）CountDownLatch

是Java并发包中的一个同步辅助类，它允许一个或多个线程等待直到在其他线程中执行的一组操作完成。的工作原理是基于一个计数器，我们在创建实例时指定计数器的初始值。每当一个指...

女爷i/ 2024年04月24日 23:10/ 0 赞/ 56 阅读

相关 Java多线程拾遗(五) 使用CountDownLatch同步线程

CountDownLatch 是什么？先看看CountDownLatch源码注释第一行给出的定义。 > 让一个或多个线程等待，直到在其他线程中执行的一组操作完成的同步

叁歲伎倆/ 2023年02月14日 07:50/ 0 赞/ 226 阅读

相关 [多线程] 多线程工具之CountDownLatch

前言在Java中, 如何启动多个线程. 随后使某项任务分步执行. (TODO 此处可以来2个说明图和小故事.) -------------------- 使用J

心已赠人/ 2022年09月15日 11:44/ 0 赞/ 278 阅读

相关多线程－CountDownLatch

好文：　　http://www.cnblogs.com/yezhenhan/archive/2012/01/07/2315652.html　　 p

素颜马尾好姑娘i/ 2022年07月15日 00:19/ 0 赞/ 263 阅读

相关 Java多线程CountDownLatch与线程池ThreadPool的使用

一. CountDownLatch是什么 CountDownLatch是一个同步工具类，它允许一个或多个线程等待，直到在其他线程中执行的一组操作完成。

小鱼儿/ 2022年05月29日 11:26/ 0 赞/ 739 阅读

相关多线程-等待其他线程完成CountDownLatch

CountDownLatch使用场景，所有线程执行完了，再执行等待的线程。比如：比赛完出成绩 CountDownLatch latch = new CountDown

小咪咪/ 2022年05月22日 22:18/ 0 赞/ 589 阅读

相关 Java线程：CountDownLatch 原理

CountDownLatch的使用 CountDownLatch是同步工具类之一，可以指定一个计数值，在并发环境下由线程进行减1操作，当计数值变为0之后，被await方法

朱雀/ 2022年03月11日 11:16/ 0 赞/ 169 阅读

相关多线程发令枪CountDownLatch

如果我们创建多个线程，希望他们在同一时刻启动，那么就会用到类似发令枪的功能，也就是countDownLatch它有两个重要的方法await()阻塞线程，countDown()每

亦凉/ 2021年12月05日 03:07/ 0 赞/ 469 阅读

相关线程-CountDownLatch的使用

CountDownLatch的使用 CountDownLatch > 遇到此问题的环境：我需要从数据库中取出5000条数据，循环数据，对每条数据每个字段进行

痛定思痛。/ 2021年09月24日 03:04/ 0 赞/ 283 阅读

相关线程学习之CountDownLatch

线程的同步方式 class Foo { public Foo() { } Co

素颜马尾好姑娘i/ 2021年09月23日 14:50/ 0 赞/ 287 阅读