循环中的嵌套任务

本文关键字：任务 嵌套 循环 | 更新日期: 2023-09-27 18:29:04

我正试图在循环中实现一个嵌套任务-这是我迄今为止的模式，但我还不确定，因为这是我第一次使用并行任务库。

父（层）任务应等待子（节点）任务完成。

    public int NestedTask(IEnumerable<MatchTier> tierNodes)
    {
        var tier = Task<int>.Factory.StartNew(() =>
        {
            Task<int> node = null;
            foreach(var n in tierNodes)
            {
                node = Task<int>.Factory.StartNew(() =>
                {
                    // Task logic goes here
                    return 1; // temp placeholder
                });
                // if a valid value is returned then exit this loop
            }
            return node.Result;
        });
        return tier.Result;
    }

子节点循环，直到返回第一个有效值，然后应该退出循环，将有效值传递给父节点。

子节点和父节点都需要超时。每个子节点将被允许运行大约3秒，之后进程将超时并询问下一个节点。

父级的总超时值约为15-20秒，之后，如果没有收到有效的响应，它也应该终止。

这看起来合乎逻辑吗？

循环中的嵌套任务

等待任务完成完成

node.Wait();

等待任务直到一些勾号完成

node.Wait(timeToWait);

或者等待他们全部完成

Task.WaitAll(tasks);

您应该阅读此处了解更多信息

如前所述，task.Wait()、task.Result（等待并获取结果）和Task.WaitAll(theTaskCollection)是实现这一点的方法。为了说明这一点，我稍微更改了您的实现，但我不确定您真正想要返回什么。我删除了外部任务，因为它似乎不需要。

public int NestedTask(IEnumerable<MatchTier> tierNodes)
{
  var tasks = tierNodes.Select(node => Task<int>.Factory.StartNew(() =>
            {
                // Task logic goes here
                return 1; // temp placeholder
            })).ToList(); // Enumerate to start tasks, not doing this would case WaitAll to start them one at a time (i believe)
  if (!Task.WaitAll(tasks, timeOutInMilliseconds))
    // Handle timeout...
  return tasks.First().Result; // Is this what you want?
}

编辑：添加修改后的解决方案。

public int NestedTask(IEnumerable<string> tierNodes)
{
  int parentTimeout = 15 * 1000;
  int childTimeout = 3 * 1000;
  var tier = Task<int>.Factory.StartNew(() =>
  {
      foreach (var n in tierNodes)
      {
          var node = Task<int>.Factory.StartNew(() =>
          {
              // Task logic goes here
              return 1;
          });
          // If we get the result we return it, else we wait
          if (node.Wait(childTimeout))
              return node.Result;
      }
      throw new Exception("did not get result!");
  });
  if (!tier.Wait(parentTimeout))
  {
      // The child will continue on running though.
      throw new TimeoutException("parent timed out");
  }
  else if (tier.Exception != null)
  {
      // We have an error
      throw tier.Exception.InnerException;
  }
  return tier.Result;
}
相关文章：