0

以下代码同时运行 2 个任务，均设置超时。

层级任务（父级）有一个总体超时值，当达到该值时，将终止进程。

在 tier 任务中，许多节点任务（子任务）同步循环，因此任务 1 必须在继续执行任务 2 之前完成，以此类推。

如果子任务未能在某个时间范围内完成，则会超时并运行下一个子任务。

如果父任务超时，则进程停止，但当前未完成的子任务仍在后台运行。子任务是第三方网络服务，如果可能的话，我想为了清洁而终止它们。

我已经查看了 microsoft 示例，但正在努力使其与我自己的代码一起使用。

简而言之，如果父级终止，它只能通过超时或异常来完成，我需要取消当前在循环内运行的子级。

任何人都知道这是如何实现的。

public int NestedTask(IEnumerable<KeyValuePair<string, int>> nodes)
{
    int parentTimeout = 20 * 1000;
    int childTimeout = 2 * 1000;

        var tier = Task<int>.Factory.StartNew(() =>
        {
            foreach (var n in nodes)
            {
                var node = Task<int>.Factory.StartNew(() =>
                {
                    Thread.Sleep(n.Value * 1000);
                    return 1;
                });

                // If we get the result we return it, else we wait
                if (node.Wait(childTimeout))
                {
                    return node.Result;
                }
            }

            // return timeout node here;
            return -1;
        });

        if (!tier.Wait(parentTimeout))
        {
            // The child will continue on running though.
            ** CANCEL SINGLE CHILD ***
            return -2;
        }
        else if (tier.Exception != null)
        {
            // We have an error
        }

        return tier.Result;
    }
4

1 回答 1

0

只需在子任务声明中指定TaskCreationOptions.AttachedToParent选项 ( MSDN )。

var node = Task<int>.Factory.StartNew(() =>
{
    Thread.Sleep(n.Value * 1000);
    return 1;
}, TaskCreationOptions.AttachedToParent);
于 2018-09-01T19:44:27.267 回答