选择异步函数的更好方法？

Question

我一直在重构我的项目中的一个常见模式，发现它并不像使用 LINQ Select 到异步函数那么简单。

对于上下文，这是当前的完成方式。

async Task<ICollection<Group>> ExecuteQueryGroupsForDomain(DomainInfo domain, int batchSize, CancellationToken ct)
{
    try
    {
        return await BlahBlahActuallyGoGetGroupsForDomainHere(domain, batchSize, ct);
    }
    catch (Exception e)
    {
        return null;
    }
}

var executeQueries = new List<Func<CancellationToken, Task<ICollection<Group>>>>();

domains.ForEach(domain =>
    executeQueries.Add(async (ct) =>
        await ExecuteQueryGroupsForDomain(domain, 123, ct)));

---

现在，如果我尝试使用 LINQ 替换 ForEach 循环部分：

var executeQueries = domains.Select(domain =>
    async (ct) => await ExecuteQueryGroupsForDomain(domain, 123, ct));

它抱怨Type arguments cannot be inferred by the usage 这让我相信我没有从Select 返回任何东西，但我显然正在返回我想要的Func。

有没有更好的方法来创建Func 的列表，最好避免显式转换？还有什么解释为什么当Select'd async 方法清楚地告诉它应该是什么类型时编译器无法推断类型？

---

需要明确的是，我确实需要将CancellationToken 传递给Func，因为它与外部令牌不同（具体而言，它是将外部令牌与另一个内部令牌联系起来的链接令牌） .

Answer 1

您可以通过使用如下所示的扩展方法获得一些可读性。它采用与 LINQ Select 方法相同的参数，但返回任务工厂而不是具体化任务。

public static IEnumerable<Func<CancellationToken, Task<TResult>>> SelectTaskFactory
    <TSource, TResult>(this IEnumerable<TSource> source,
    Func<TSource, CancellationToken, Task<TResult>> selector)
{
    return source.Select(item =>
    {
        return new Func<CancellationToken, Task<TResult>>(ct => selector(item, ct));
    });
}

使用示例：

var executeQueries = domains.SelectTaskFactory(async (domain, ct) =>
{
    return await ExecuteQueryGroupsForDomain(domain, 123, ct);
}).ToList();

executeQueries 变量的类型是List<Func<CancellationToken, Task<ICollection<Group>>>>。

Answer 2

问题在于select的返回，因为编译器并不清楚返回的类型是什么。所以，你需要明确返回的类型，这里有两种方式：

executeQueries = domains.Select(domain => 
    new Func<CancellationToken, Task<ICollection<Group>>>(token => 
        this.ExecuteQueryGroupsForDomain(domain, 123, token))).ToList();

executeQueries = domains
    .Select<DomainInfo, Func<CancellationToken, Task<ICollection<Group>>>>(domain =>
        ct => this.ExecuteQueryGroupsForDomain(domain, 123, ct)).ToList();

================================================ ========================

编辑 1： 编译器无法从 lambda 表达式推断类型，因为 lambda 只是匿名方法的简写，而不是类型。因此，您需要明确并指出方法的返回类型，如果返回是基委托或其他委托类型，如 Action、Func 等。请查看 this 其他答案，其中根据错误编译器解释C# 4 规范。

如果您需要将原始代码转换为更具可读性的内容，我认为没有其他方式更具可读性。以下是可以编写代码的其他方式：

foreach (var domain in domains) {
    executeQueries.Add(token => this.ExecuteQueryGroupsForDomain(domain, 123, token));
}
executeQueries.AddRange(domains
    .Select(domain => (Func<CancellationToken, Task<ICollection<Group>>>) (token => 
        this.ExecuteQueryGroupsForDomain(domain, 123, token))));
executeQueries =
    (from domain in domains
    select new Func<CancellationToken, Task<ICollection<Group>>>(token => 
        this.ExecuteQueryGroupsForDomain(domain, 123, token))).ToList()

Answer 3

你真的需要Func的吗？

如果实际的CancellationToken 已经存在，您可以使用以下内容。

// create and start a Task for each domain
var executeQueryTasks = domains.Select(domain => ExecuteQueryGroupsForDomain(domain, 123, ct));

// wait until all tasks are finished and get the result in an array
var executedQueries = await Task.WhenAll(executeQueryTasks);