Haskell 中的并行映射

Question

是否有一些可以并行评估列表的 map 替代品？我不需要它来偷懒。

类似于： pmap :: (a -> b) -> [一]-> [b] 让我 pmap costly_function big_list 并使我的所有核心都处于 100%。

Answer 1

参阅并行包：

ls `using` parList rdeepseq

是的，请 通过 rdeepseq 策略并行评估列表中的每个元素。请注意，如果您的元素太便宜而无法获得并行评估每个元素的好处（因为它节省了每个元素的火花），则使用具有良好块值的 parListChunk 可能会带来更好的性能。

编辑：根据你的问题，我觉得我应该解释为什么这是一个答案。这是因为 Haskell 很懒！ 这一说法

let bs = map expensiveFunction as

考虑一下“没有任何内容已被评估” 。您刚刚创建了一个映射 expenseFunction 的 thunk。那么我们如何并行评估它呢？

let bs = map expensiveFunction as
    cs = bs `using` parList rdeepseq

现在，在以后的计算中不要使用 bs 列表，而是使用 cs 列表。 IOW，您不需要并行映射，您可以使用常规（惰性）映射和并行评估策略。

编辑：如果你环顾四周，你会看到 parMap 函数执行我在此展示的操作，但包装在一个辅助函数中。

针对您的评论，以下代码不适合您吗？它对我有用。

import Control.Parallel.Strategies

func as =
        let bs = map (+1) as
            cs = bs `using` parList rdeepseq
        in cs

Answer 2

除了像 Tom 所描述的那样，您自己使用显式策略之外，parallel 包 也导出parMap：

 parMap :: Strategy b -> (a -> b) -> [a] -> [b]

其中策略参数类似于rdeepseq。

par-monad 包中还有 parMap （你走出了纯 Haskell，进入了并行 monad）：

 parMap :: NFData b => (a -> b) -> [a] -> Par [b]

par-monad 包是 记录在此处。