F和PLINQ扩展方法

如果尚未使用.NET 4.0,可以将其编写为:

#r "System.Threading"
open System.Linq

let someArray = [|"abc"; "def"|]

someArray.AsParallel<string>()
|> Seq.filter (fun s -> s.Length = 3)
|> Seq.length

来吧.NET 4.0,你只需写:

let someArray = [|"abc"; "def"|]

someArray
|> Array.Parallel.filter (fun s -> s.Length = 3)
|> Array.length

与LINQ扩展方法相比,F更喜欢使用Seq模块。但是,在fsharp.powerpack.linq程序集中有一些辅助函数可用。

如果我没记错的话,让plinq和f很好地合作是微软开发团队的任务清单,尽管我不确定它会出现在.NET 4.0中。但是,F确实有 Asynchronous Workflows 这与plinq非常相似(只是它基于列表理解,这是标准的功能方式)。我似乎找不到在f_中提到对并行扩展(plinq/tpl)更好支持的文章,所以不要在上面引用我,但我肯定我在某个地方看到了它。

除了MSDN页面之外, this article 这似乎是对这个话题的一个很好的介绍。

还有 this blog series ( 在f中使用plinq# )如果您仍然喜欢使用PLINQ而不是异步工作流,那么阅读它可能很方便。

扩展方法只是将对象作为第一个参数的静态方法,因此您应该能够使用

ParallelEnumerable.AsParallel(someArray).Count(...)