将Task[]转换为IEnumerable<Task<T>>时遇到的技术问题

错误原因 #

• 你定义的tasks是Func<Task>[]（返回无返回值Task的委托数组），而WithMaxConcurrency方法要求的是IEnumerable<Task<T>>（有返回值的任务集合），两者类型不兼容。
• Task（无返回值）和Task<T>（有返回值）是不同类型，且Task不是Task<T>的子类，无法直接强制转换。

解决方案 #

根据你的任务是否有返回值，分两种情况处理：

情况1：任务无返回值（jack/roy/sam返回Task） #

修改WithMaxConcurrency，增加一个针对无返回值Task的重载方法，同时将Func<Task>委托转换为实际的Task集合：

// 针对无返回值Task的重载方法
private static IEnumerable<Task> WithMaxConcurrency(IEnumerable<Task> tasks, int maxParallelism)
{
    using SemaphoreSlim maxOperations = new SemaphoreSlim(maxParallelism);
    return tasks.Select(async task =>
    {
        await maxOperations.WaitAsync();
        try
        {
            await task;
        }
        finally
        {
            maxOperations.Release();
        }
    });
}

// 调用代码
var tasks = new Func<Task>[]
{
    () => jack(),
    () => roy(),
    () => sam()
};

// 先将Func<Task>转换为Task集合，再传入方法
var taskCollection = tasks.Select(f => f());
await Task.WhenAll(WithMaxConcurrency(taskCollection, 3));

情况2：任务有返回值（jack/roy/sam返回Task，比如Task） #

调整任务数组的类型为Func<Task<T>>，并将委托转换为Task<T>集合后传入原方法：

// 假设jack/roy/sam返回Task<string>
var tasks = new Func<Task<string>>[]
{
    () => jack(),
    () => roy(),
    () => sam()
};

// 转换为Task<string>集合
var taskCollection = tasks.Select(f => f());
// 直接调用泛型方法，T会自动推断为string
await Task.WhenAll(WithMaxConcurrency(taskCollection, 3));

优化原泛型方法 #

原方法使用ContinueWith的写法可以简化为async/await，同时加上using确保SemaphoreSlim被正确释放：

private static IEnumerable<Task<T>> WithMaxConcurrency<T>(IEnumerable<Task<T>> tasks, int maxParallelism)
{
    using SemaphoreSlim maxOperations = new SemaphoreSlim(maxParallelism);
    return tasks.Select(async task =>
    {
        await maxOperations.WaitAsync();
        try
        {
            return await task;
        }
        finally
        {
            maxOperations.Release();
        }
    });
}

内容的提问来源于stack exchange，提问作者Jack