目前的设置是这样的
array
|> Seq.map (fun item -> async { return f item})
|> Async.Parallel
|> Async.RunSynchronously
问题是,这往往会创建太多线程并定期崩溃应用程序.
在这种情况下如何限制线程数(比如说,Environment.ProcessorCount)？
解决方法
如果要并行化采用数组(或任何序列)作为输入的cpu密集型计算,那么最好使用
F# PowerPack中的PSeq模块(虽然仅在.NET 4.0上可用).它提供了许多标准Array.xyz函数的并行版本.有关更多信息,您还可以查看0700个样本中的
F# translation.
array |> PSeq.map f
|> PSeq.toArray
这两个选项之间的一些差异是：
> PSeq是使用.NET 4.0中的任务并行库(TPL)创建的,该版本针对处理大量cpu密集型任务进行了优化.
>异步在F#库中实现,并支持异步(非阻塞)操作,例如并发运行的操作中的I / O.
总之,如果您需要异步操作(例如I / O),那么Async是最佳选择.如果你有大量的cpu密集型任务,那么PSeq可能是更好的选择(在.NET 4.0上)
