多线程 – 如何限制为F#中的异步Seq.map操作创建的线程数？

目前的设置是这样的

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上)