为了账号安全,请及时绑定邮箱和手机立即绑定

Java 8:并行流等待所有线程完成任务

Java 8:并行流等待所有线程完成任务

MM们 2021-06-07 13:02:30
使用并行流处理具有大量数据的大量文件并将它们写入特定格式。这是代码:public static void main(String[] args) throws Exception {   mergeController.compactFiles();   mergeController.writeMergedFlag();}private void compactFiles() {  Set<String> events = this.listSubDirectoryNames(inputDir);  events.parallelStream().forEach(event -> writeEvent(event, eventSchemaMap.get(event), this.configuration));}这些方法不返回任何内容,因为它们只是在写入文件。我看到writeMergedFlag()主要是在运行该过程 1.5 小时后被调用。这里有什么问题?是堆空间问题还是其他问题?我以前没有遇到过这种类型的问题。
查看完整描述

2 回答

  • 2 回答
  • 0 关注
  • 271 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信