Monoid instance for ParMap?

Question

猫中是否有用于scala.collection.parallel.ParMap的现有Monoid实例？ 我不这么认为，但我不确定。

如果没有，那么我将如何创建这样的实例？ 这是我到目前为止所拥有的...

import cats._
import implicits._
def parMapMonoid[K, V]: Monoid[ParMap[K, V]] = {
new Monoid[ParMap[K, V]] {
def combine(v1: ParMap[K, V], v2: ParMap[K, V]): ParMap[K, V] = {
???
}
def empty: ParMap[K, V] = {
ParMap.empty[K, V]
}
}
}

。您可以假定为类型V定义了适当的Monoid实例。 对于我type V=Int中的特定用例.

Answer 1

这会逐点组合值，键k的缺失值被替换为V-monoid的单位元素：

def parMapMonoid[K, V](implicit vMon: Monoid[V]): Monoid[ParMap[K, V]] = {
new Monoid[ParMap[K, V]] {
def combine(v1: ParMap[K, V], v2: ParMap[K, V]): ParMap[K, V] = {
val allKeys = v1.keys ++ v2.keys
(for (k <- allKeys) yield {
(k, vMon.combine(
v1.getOrElse(k, vMon.empty),
v2.getOrElse(k, vMon.empty)
))
})(collection.breakOut)
}
def empty: ParMap[K, V] = {
ParMap.empty[K, V]
}
}
}

由于allKeys也是一个并行集合，因此整个构造仍应"合理并行化"。

Answer 2

如果您需要以某种方式组合ParMap那么您可以使用常规Monoid[Map[_, _]]。不，不幸的是，你不能，因为ParMap不是Map的子类型。 但是如果你想利用表意FP，你应该避免像ParMap这样的结构，因为它们混合了数据的描述和执行模型。