问题描述
我正在使用并行流来处理大型数据集。但它给出了不一致的结果。使用的数据库是 Postgres。我有定义了级别的分层数据。
例如,我在层次结构中有 5 个级别的数据。我首先处理最低级别(此处为 5 个)节点,然后坚持到数据库。然后当我在处理上一级(这里是4)时,我必须获取已经保存在5级的数据并处理它并将4级数据保存到db。
我为每个级别的处理使用并行流。一旦第 5 级进程完成,当我们在处理第 4 级节点时尝试获取该数据时,保存的数据不会反映出来。
当我在下面的代码中删除“parallelStream()”时,一切正常。但是太费时间了
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)