c# – 是否有默认方式让第一个任务成功完成？

发布时间：2020-12-15 18:13:10 所属栏目：百科来源：网络整理

导读：让我们说我有几个任务： void Sample(IEnumerableint someInts){ var taskList = someInts.Select(x = DownloadSomeString(x));}async Taskstring DownloadSomeString(int x) {...} 我想得到第一个成功任务的结果.所以,基本的解决方案是写下这样的东西： var

让我们说我有几个任务：

void Sample(IEnumerable<int> someInts)
{
    var taskList = someInts.Select(x => DownloadSomeString(x));
}

async Task<string> DownloadSomeString(int x) {...}

我想得到第一个成功任务的结果.所以,基本的解决方案是写下这样的东西：

var taskList = someInts.Select(x => DownloadSomeString(x));
string content = string.Empty;
Task<string> firstOne = null;
while (string.IsNullOrWhiteSpace(content)){
    try
    {
        firstOne = await Task.WhenAny(taskList);
        if (firstOne.Status != TaskStatus.RanToCompletion)
        {
            taskList = taskList.Where(x => x != firstOne);
            continue;
        }
        content = await firstOne;
    }
    catch(...){taskList = taskList.Where(x => x != firstOne);}
}

但是这个解决方案似乎运行N(N-1)… K任务.其中N是someInts.Count和K是任务中第一个成功任务的位置,因此它重新运行除WhenAny捕获的任务之外的所有任务.
那么,有没有办法让第一个任务成功完成并运行最多N个任务？ (如果成功的任务将是最后一个)

解决方法

“第一个成功的任务”的问题是如果所有任务都失败了怎么办？这是一个 really bad idea to have a task that never completes.

我假设你想要传播最后一个任务的异常,如果它们都失败了.考虑到这一点,我会说这样的事情是合适的：

async Task<Task<T>> FirstSuccessfulTask(IEnumerable<Task<T>> tasks)
{
  Task<T>[] ordered = tasks.OrderByCompletion();
  for (int i = 0; i != ordered.Length; ++i)
  {
    var task = ordered[i];
    try
    {
      await task.ConfigureAwait(false);
      return task;
    }
    catch
    {
      if (i == ordered.Length - 1)
        return task;
      continue;
    }
  }
  return null; // Never reached
}

该解决方案建立在OrderByCompletion extension method的part part上;在Jon Skeet和Stephen Toub也存在替代实施方式.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!