从scala平行收藏转换到定期收藏

发布时间：2020-12-16 09:39:30 所属栏目：安全来源：网络整理

导读：我正在尝试从并行集合转换为常规映射。根据api，如果我在任何适当定义的并行集合中调用map，它应该返回一个标准的Map，但是它将ParMap返回到一个扁平化的迭代集合。我有一个 val task: Stream[Future[Iterable[Tuple2[String,String]]]] 我从中得到： val r

我正在尝试从并行集合转换为常规映射。根据api，如果我在任何适当定义的并行集合中调用map，它应该返回一个标准的Map，但是它将ParMap返回到一个扁平化的迭代集合。

我有一个

val task: Stream[Future[Iterable[Tuple2[String,String]]]]

我从中得到：

val res: ParSeq[Iterable[Tuple2[String,String]]] = tasks.par.map(f => f.apply())

最后：

val finalresult = res.flatten.toMap

不幸的是，finalResult的类型是ParMap [String，String]。

另一方面，如果我称之为：

tasks.par.map(f => f.apply()).reduce(_++_).toMap

那么返回类型是Map [String，String]。

有人可以告诉我为什么会这样吗？和(出于好奇心)当scala不会让我失败时，我如何强制将ParMap转换成地图？

解决方法

当你明确地从顺序到并行收集通过.par，你回到顺序通过.seq。由于集合和映射具有并行实现，因此toMap和toSet调用将使集合保留在当前域中。

减少工作的例子，因为它很好地减少了收集(外部ParSeq消失，留下了内部(顺序)Iterable [Tuple2 […]])。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!