C# 中异步委托的 VB.NET 等价物是什么？

Question

我正在尝试将以下扩展方法 (source) 从 C# 转换为 VB：

public static Task ForEachAsync<T>(this IEnumerable<T> source,
                                   int dop, Func<T, Task> body)
{
    return Task.WhenAll(
        from partition in Partitioner.Create(source).GetPartitions(dop)
        select Task.Run(async delegate {
            using (partition)
                while (partition.MoveNext())
                    await body(partition.Current);
        }));
}

delegate 的常规等效项是 Sub()，AFAIK，但我没想到它会在这种情况下工作，因为 Async 关键字（它没有）。所以，我尝试改用Function()：

<System.Runtime.CompilerServices.Extension>
Public Function ForEachAsync(Of T)(source As IEnumerable(Of T),
                                   dop As Integer, body As Func(Of T, Task)) As Task
    Return Task.WhenAll(
        From partition In Partitioner.Create(source).GetPartitions(dop)
        Select Task.Run(Async Function() 'As Task '<-- see below.
                            Using partition
                                Do While partition.MoveNext()
                                    Await body(partition.Current)
                                Loop
                            End Using
                        End Function))
End Function

但这仍然无法编译并显示以下错误：

• WhenAll:

  Overload resolution failed because no accessible 'WhenAll' can be called with these arguments:
      'Public Shared Overloads Function WhenAll(Of TResult)(tasks As IEnumerable(Of Task(Of TResult))) As Task(Of TResult())': Type parameter 'TResult' cannot be inferred.
      'Public Shared Overloads Function WhenAll(Of TResult)(ParamArray tasks As Task(Of TResult)()) As Task(Of TResult())': Type parameter 'TResult' cannot be inferred.
  

• Await body(partition.Current):

  'Await' 只能在第一个查询表达式中使用 初始 'From' 子句的集合表达式或在 'Join' 子句的集合表达式。

• [警告]Async Function()：^{（如果我添加As Task，它就会消失）}

  函数 '<anonymous method>' 不会在所有代码上返回值 路径。空引用异常可能在运行时发生，当 使用结果。

我做错了什么？在 VB 中执行此操作的正确方法是什么？

Answer 1

在 C# 中，可以使用 delegate type 或使用调用运算符 () 后跟 => 标记作为 lambda 运算符来调用匿名方法来表示异步 Lambda：

Task.Run(async ()=> { } );
Task.Run(async delegate { } );

在 VB.Net 中，可以使用 Lambda 表达式调用匿名方法，使用 Sub() 或 Function()，内联和 Sub / End Sub、Function() / End Function 块：

Task.Run(Async Sub() [operation on captured variables])
Task.Run(Sub()
             [operation on captured variables]
         End Sub))

Task.Run(Async Function() [operation on captured variables])
Task.Run(Function()
             Return [operation on captured variables]
         End Function))

VB.Net 的 LINQ to SQL 不允许在 Select 子句中等待，因为：

Await 只能在第一个查询表达式中使用 初始 From 子句的集合表达式或在 Join 子句的集合表达式

Stephen Toub 的 Async/Await FAQ 中引用了它。

Select Task.Run(Async Function() ... ) 尝试返回 IEnumerble(Of TResult) 而不是 IEnumerble(Of Task)。

Language-Integrated Query (LINQ) (Visual Basic) 中的更多信息。

相反，LINQ to Objects - 在没有其他中间提供者的情况下使用 IEnumerable/IEnumerable<T> 集合 - 确实允许 Select 方法上的异步/等待模式：

<Extension>
Public Function ForEachAsync(Of T)(source As IEnumerable(Of T), dop As Integer, body As Func(Of T, Task)) As Task
    Return Task.WhenAll(
        Partitioner.Create(source).GetPartitions(dop).
        Select(Function(p) (
                   Task.Run(Async Function()
                                Using p
                                    While p.MoveNext()
                                        Await body(p.Current)
                                    End While
                                End Using
                            End Function))))
End Function

LINQ to SQL 的 C# 版本允许这样做。
为什么，因为同样的规则也应该适用于 C# 实现？

The .NET Language Strategy:

C#：

我们将不断发展 C# 以满足开发人员不断变化的需求和 仍然是最先进的编程语言。我们将创新 积极进取，同时非常小心地保持在 语言。

VB.Net：

我们将继续专注于跨语言工具体验， 认识到许多 VB 开发人员也使用 C#。我们将专注 在VB流行的核心场景和领域进行创新。

因此，2010 年声明的 VB and C# Coevolution 发生了变化：C# 和 VB.Net 功能更新已解耦。因此，考虑到新的语言策略，VB.Net 和 C# 不再显示大致相同的采用率。

Answer 2

这不是问题的真正答案，但如果它是真正的异步代码，则无需对执行进行分区：

<System.Runtime.CompilerServices.Extension>
Public Function ForEachAsync(Of T)(
    source As IEnumerable(Of T),
    body As Func(Of T, Task)) As Task
    Return Task.WhenAll(        
        From item In source
        Select body(item))
End Function