好资源导航 » 文章资讯 » 如何使用CountDownLatch同步java多线程

如何使用CountDownLatch同步java多线程

2023-07-19 05:03:03 58

最近写了一个并发幂等测试，用线程池加入多个线程，同时启动，领导觉得这样有一定的风险，要求更严格一点，把所有的线程加入池中，然后同时启动。

本来有多种方法，因为我们需要从多个线程中获取返回值，所以我们用CountDownLatch来同步多线程。CyclicBarrier也是可以同步多线程的，但因为其无法获取返回值，最后只能选择CountDownLatch.

因公司的代码不便共享，这里只提供一小部分代码。

CountDownLatchlatch=newCountDownLatch(1);

ExecutorServicepool;
if(concurrentNum!=null&&concurrentNum<=maxConcurrentNum&&concurrentNum>0){
pool=Executors.newFixedThreadPool(concurrentNum);
}else{
concurrentNum=defaultConcurrentNum;
pool=Executors.newFixedThreadPool(defaultConcurrentNum);
}
for(inti=0;i(){
@Override
publicObjectcall()throwsException{
latch.await();
ObjectretObj=executeApi();
returnretObj;
}
});
resultList.add(res);
}
latch.countDown();
for(inti=0;i
这里顺便提一下，latch在中文中就是门栓的意思，这样就很好理解了，当有门栓时，latch.await()的线程都在等待，只有当门栓的个数为0时那些线程才能同时释放出来，所以能同步运行多线程。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

返回顶部
514930285
czq8825@qq.com

如何使用CountDownLatch同步java多线程

热门推荐

随机推荐