f# - Fsharp - 如何将序列转换为 ParallelQuery？

Question

我有一个我正在使用 ParallelEnumerable.Aggregate() 处理的对象序列，但是 Aggregate 函数的源需要是 ParallelQuery。

如何将序列转换为 ParallelQuery？

Answer 1

您可以使用AsParallel

open System.Linq

let (inputSeq: seq<int>) = [1;2;3]
let parallel = inputSeq.AsParallel()

Answer 2

PSeq在 PowerPack 中为并行查询提供了一个 F# 友好的界面。它定义了一个ofSeq函数，但无论出于何种原因，它都不是公开的。

您可以将其重新创建为模块扩展。