haskell - 并行 parMap 和策略

Question

对并行策略有疑问，parMap (控制.并行.策略)

大约是 parMap rseq等价于 parMap rpar .

由于parMap使用 parList它并行计算，因此使用 rseq或 rpar将与 WHNF 并行评估。不是吗？

更新:

自从

parMap strat f = (`using` parList strat) . map f

parList = parTraversable

parTraversable strat = evalTraversable (rpar `dot` strat)

evalTraversable = traverse

strat2 `dot` strat1 = strat2 . runEval . strat1

parMap rseq使用策略

rpar `dot` rseq

这使:

rpar . runEval . rseq

这使:

(\x -> x `par` return x) . runEval . (\x -> x `pseq` return x)

很难去想结果。

更新:

我明白了，惰性求值首先采用组合的第一个函数，并且

(\x -> x `par` return x)

授予可遍历容器中的每个元素将在可能的情况下触发并行计算。

所以我们可以添加 (rpar dot rseq) 等价于 (rseq dot rpar)，不是吗？

那 parMap rpar是多余的，因为它为每个可遍历元素生成两个 Spark 。 !!

Answer 1

快速烟雾测试表明是的 parMap rseq和 parMap rpar两者都得到并行评估。

import Control.Parallel.Strategies

fib 0 = 1
fib 1 = 1
fib n = fib (n-1) + fib (n-2)

main = print resultPlain where
  resultPlain = [fib 34, fib 34, fib 34, fib 34]
  resultPar   = parMap rpar id [fib 34, fib 34, fib 34, fib 34]
  resultSeq   = parMap rseq id [fib 34, fib 34, fib 34, fib 34]

然后，使用每种 result_____我为编译的二进制文件计时

ghc -threaded --make rpar
time ./rpar +RTS -N4

看到了 resultPlain比 resultPar 长得多或 resultSeq (大约长 2 倍)和 resultPar和 resultSeq时间相对一致。

GHC 对 Eval 的实际解释的更多细节monad 是缺乏的，但鉴于 parMap strat f = withStrategy (parList strat) . map f连同这个实验的结果，我有信心说列表中的每个元素都被激发以对 WHNF 进行评估。