版权声明:此博客内容均是本人精心整理文档,方便大家学习交流,如有不妥之处,请联系我删除 https://blog.csdn.net/u012489091/article/details/84985560
CyclicBarrier 的作用
- 假设有线程B、线程C、线程D
- BCD线程都需要执行到await方法后,才可以继续执行
- 总结:说白了就是,BCD线程要相互等待,都执行了await()方法才可以继续执行
CyclicBarrier 例子:
/**
* 实现功能是将goodsReqDtoList作为calcEstimateAmount方法的入参,然后将最终的结果放入map中进行返回
* 1.根据 goodsReqDtoList 的长度,判断我们要开多少个线程
* 2.将每个线程获得的结果放入 map 中,等到所有线程都计算完,将结果进行返回
* @param goodsReqDtoList CommonGoodsReqDto,支持多个商品属性的查询
* @return
*/
@Override
public Map<String, Long> getRebatePlanAmount(List<CommonGoodsReqDto> goodsReqDtoList) {
// 线程执行数量,判断要开多少个线程执行
int threadNum;
int everyListCount = 5; // 每个list中有5条数据
if (goodsReqDtoList.size() % everyListCount == 0) {
threadNum = goodsReqDtoList.size() / everyListCount;
} else {
threadNum = goodsReqDtoList.size() / everyListCount + 1;
}
final Map<String, Long> resMap = new ConcurrentHashMap<>();
final CyclicBarrier cyclicBarrier = new CyclicBarrier(threadNum);
List<CommonGoodsReqDto> goodsList = new ArrayList<>();
for (int i = 0; i < goodsReqDtoList.size(); i++) {
goodsList.add(goodsReqDtoList.get(i));
if ((i == goodsReqDtoList.size() - 1) || (i + 1) % everyListCount == 0) {
final List list = goodsList;
new Thread(new Runnable() {
@Override
public void run() {
// 将每个线程获得的结果放到 resMap 中
resMap.putAll(calcEstimateAmount(list));
try {
cyclicBarrier.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println("AAA");
}
}).start();
}
if ((i + 1) % everyListCount == 0) {
goodsList = new ArrayList<>();
}
}
return resMap;
}