Java多线程问题之同步器CyclicBarrier

还是上次的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个进程同步进行互不干扰。

分享名称：Java多线程问题之同步器CyclicBarrier
路径分享：http://www.mswzjz.cn/qtweb/news2/322352.html

攀枝花网站建设、攀枝花网站运维推广公司-贝锐智能，是专注品牌与效果的网络营销公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 贝锐智能