博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java多线程问题之同步器CyclicBarrier
阅读量:6695 次
发布时间:2019-06-25

本文共 849 字,大约阅读时间需要 2 分钟。

还是上次的oracle迁移到mysql的遗留问题,当我在查看数据的时候,发现两个库数据量不一致。最后证实了我的看法,我修改代码时将10个进程简成1个单线程来完成了。所以数据量会少那么多呢。

原因很简单当时就是这个函数CyclicBarrier,当时不理解具体的意思:

if (sessionParameter.getSourceThreadNum() > 1) { System.out.println("多线程运行"); CyclicBarrier barrier = new CyclicBarrier(sessionParameter .getSourceThreadNum() + 2); for (int i = 0; i <= sessionParameter.getSourceThreadNum(); i++) { dataSyncThread dataSync = new dataSyncThread(barrier, i, sDataSource, tDataSource, sessionParameter); dataSync.start(); } long start = System.currentTimeMillis(); barrier.await(); barrier.await(); long end = System.currentTimeMillis();在实际应用中,有时候需要多个线程同时工作以完成同一件事情,而且在完成过程中,往往会等待其他线程都完成某一阶段后再执行,等所有线程都到达某一个阶段后再统一执行。 其中,的barrier就是相当于一个阻断,障碍器,CyclicBarrier最重要的属性就是参与者个数,另外最要方法是await()。当所有线程都调用了await()后,就表示这些线程都可以继续执行,否则就会等待。只有达到CyclicBarrier(int number)中number的数量,才能使程序中的10个进程同步进行互不干扰。

转载地址:http://yovoo.baihongyu.com/

你可能感兴趣的文章
smarty获取php中的变量
查看>>
linux中wget 、apt-get、yum rpm区别
查看>>
Scrapy 爬虫框架入门
查看>>
pl/sql编程(十五)
查看>>
查看端口是否被占用
查看>>
request对象的常用属性和方法
查看>>
leetcode:Rotate List
查看>>
webpack 使用环境变量
查看>>
NGOSS 初识
查看>>
16-组件的创建
查看>>
StatefulSet(一):拓扑状态
查看>>
python例题21--30
查看>>
历届试题 带分数
查看>>
PhotoShop基础工具 -- 移动工具
查看>>
Android学习笔记(八)——四种基本布局
查看>>
爬虫--Scrapy框架的基本使用
查看>>
(最小生成树) Building a Space Station -- POJ -- 2031
查看>>
maven常用技巧
查看>>
Luogu_2876_[USACO07JAN]解决问题Problem Solving
查看>>
C#多态问题
查看>>