Async Task.WhenAll with timeout

Question

在新的异步dotnet 4.5库中是否有办法在Task.WhenAll方法上设置超时.我想获取几个源并在说5秒后停止并跳过未完成的源.

Answer 1

您可以将结果Task与Task.Delay()使用结合起来Task.WhenAny():

await Task.WhenAny(Task.WhenAll(tasks), Task.Delay(timeout));

如果您想在超时的情况下收获已完成的任务:

var completedResults =
  tasks
  .Where(t => t.Status == TaskStatus.RanToCompletion)
  .Select(t => t.Result)
  .ToList();

Answer 2

我认为一个更清晰,更强大的选项,也可以执行异常处理,将Task.WhenAny每个任务与超时任务一起使用,完成所有已完成的任务并过滤掉超时任务,并使用await Task.WhenAll()而不是Task.Result收集所有结果.

这是一个完整的工作解决方案:

static async Task<TResult[]> WhenAll<TResult>(IEnumerable<Task<TResult>> tasks, TimeSpan timeout)
{
    var timeoutTask = Task.Delay(timeout).ContinueWith(_ => default(TResult));
    var completedTasks = 
        (await Task.WhenAll(tasks.Select(task => Task.WhenAny(task, timeoutTask)))).
        Where(task => task != timeoutTask);
    return await Task.WhenAll(completedTasks);
}

Answer 3

查看Microsoft 基于任务的异步模式概述中的"早期救助"和"Task.Delay"部分.

早期救助.由t1表示的操作可以在具有另一个任务t2的WhenAny中分组,并且我们可以等待WhenAny任务.t2可以表示超时,取消或其他一些信号,这些信号将导致在完成t1之前完成WhenAny任务.