如何转换iEnumerable＆lt; task＆lt; t＆gt;＆gt; ienumerable＆lt; lt; task＆lt; t＆gt;＆gt;＆gt;在C＃中？

Question

我有一个私人功能，它将 iEnumerable＆lt; func＆lt; task＆lt; t＆gt;＆gt;＆gt; 作为输入。我的任务＆lt; t＆gt;＆gt; 要通过。如何将转换为任务＆lt; t＆gt;＆gt; ienumerable＆lt; func＆lt; task＆lt; task＆lt; t＆lt;

Code Sample:

private static async Task<IEnumerable<T>> ParallelizeAsync<T>(IEnumerable<Func<Task<T>>> funcs, int maxParallelism)
{
    var sem = new SemaphoreSlim(maxParallelism, maxParallelism);
    var result = funcs.Select(async f =>
    {
        await sem.WaitAsync();
        var r = await f();
        sem.Release();
        return r;
    });
    return await Task.WhenAll(result);
}

var functasks = Enumerable.Range(1, 5).Select(async x => await Task.FromResult(x));
var help = ParallelizeAsync<IEnumerable<int>>(functasks, 10);

I'm getting the following error,

无法转换 'System.Collections.generic.Ienumerable＆lt; system.threading.tasks.task＆gt;' 到 'system.collections.generic.Ienumerable＆lt; system.func＆lt; system.threading.tasks.tasks.task＆lt; system.collections.generic.eneric.ienumosite

我想念一些演员吗？

Answer 1

因此，您需要创建一个 Func，当调用它时，它会返回您构造的已完成的 Task。最简单的方法很简单：

() => theTask

所以要么：

var functasks = Enumerable.Range(1, 5).Select(x => () => Task.FromResult(x));

要么给定 functasks：

var help = ParallelizeAsync<int>(functasks.Select(x => () => x), 10);

---

您的另一个问题是您正在调用：

var help = ParallelizeAsync<IEnumerable<int>>(functasks, 10)

由于 ParallelizeAsync 的签名是：

private static async Task<IEnumerable<T>> ParallelizeAsync<T>(IEnumerable<Func<Task<T>>> funcs, int maxParallelism)

这意味着 T 是一个 IEnumerable，因此 ParallelizeAsync 需要一个IEnumerable>>。这与你的问题的其余部分不匹配。

您可能打算调用 ParallelizeAsync(...)。

Answer 2

var l = new List<Task<bool>>();
var f = new List<Func<Task<bool>>>();
f = l.Select<Task<bool>, Func<Task<bool>>>(x => () => x).ToList();

对你来说，只需改变这一行

var help = ParallelizeAsync<IEnumerable<int>>(functasks.Select(t => () => t) , 10);

Answer 3

您需要将一个函数传递给返回另一个函数的Select：

var functasks = Enumerable.Range(1, 5)
    .Select(x => async () => await Task.FromResult(x));

在这个简单的示例中，async / await是多余的：

var functasks = Enumerable.Range(1, 5).Select(x => () => Task.FromResult(x));

---

请注意，您是还错误地调用了ParallelizeAsync；通过提供 IEnumerable 作为通用参数，funcs 变为 IEnumerable>>> 。

您应该简单地传递 int:

var help = ParallelizeAsync<int>(functasks, 10);

或者让类型推断来完成工作：

var help = ParallelizeAsync(functasks, 10);