目前的设置是这样的
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上)
原文地址:https://www.jb51.cc/java/129985.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。