4

我正在使用 F# 进行并行编程。对于固定数量的元素，例如 2 个元素 a1、a2 和一个函数 f，我可以执行以下操作：

let t1 = Task.Factory.StartNew(fun () -> f a1)
let t2 = Task.Factory.StartNew(fun () -> f a2)
Task.WaitAll(t1, t2)
t1.Result, t2.Result

我想知道如何对元素列表做同样的事情：

let ts = List.map (fun a -> Task.Factory.StartNew(fun () -> f a))
Task.WaitAll(ts)
List.map (fun (t: Task<_>) -> t.Result) ts

Visual Studio 发现 Task.WaitAll 不能接受 Task< T > 列表作为其参数。Task.WaitAll 可以将 Task [] 作为其参数，但这没有任何意义，因为我需要获取 Result 进行下一次计算。

4

3 回答 3

8

正如 Robert 解释的那样，如果您想调用WaitAll，则必须将元素序列转换为基本类型Task，然后将其转换为数组。您可以定义扩展成员Task以使任务更简单：

type System.Threading.Tasks.Task with
  static member WaitAll(ts) =
    Task.WaitAll [| for t in ts -> t :> Task |]

我正在使用数组理解和强制转换，而不是Seq.cast因为Seq.cast需要无类型IEnumerable- 所以 F# 为扩展方法推断出更好的类型。

另一种选择是根本不调用WaitAll- 如果你不这样做，Result属性将阻塞，直到任务完成。这意味着无论如何你都会阻塞线程（可能会有更多的阻塞，但我不确定它是否会影响性能太多）。如果您使用List.map收集所有结果，则行为几乎相同。

于 2011-02-25T13:53:18.197 回答
4

这是一个不幸的设计。Task.WaitAll 使用 c# params 关键字来允许您指定多个参数并将它们作为方法中的数组。它还使用 C# 的隐式强制转换，以便您可以将Task<T>. 在 F# 中，您必须自己通过显式转换并转换为数组来执行此操作：

let ts = [| 
     Task.Factory.StartNew(fun () -> 1)
     Task.Factory.StartNew(fun () -> 2)
     |]
Task.WaitAll(ts |> Seq.cast<Task> |> Array.ofSeq)

现在您可以从ts.

于 2011-02-25T12:57:15.450 回答
1

数组也有地图，所以没有理由不能将任务放在数组中。

或者您可以转换为仅用于等待的数组...

于 2011-02-25T11:54:42.840 回答