我正在使用并行流来处理大型数据集。但它给出了不一致的结果。使用的数据库是 Postgres。我有定义了级别的分层数据。
例如，我在一个层次结构中有 5 个级别的数据。我首先处理最低级别（这里是 5 个）节点，持久保存到数据库。然后，当我在处理上一层（此处为 4）时，我必须获取已经保存在 5 级中的数据并对其进行处理并将 4 级数据保存到 db。
我正在为每个级别处理使用并行流。一旦第 5 级的过程完成，并且当我们尝试获取处理第 4 级节点的数据时，保存的数据不会反映。
当我在下面的代码中删除“parallelStream()”时，一切正常。但这需要太多时间