c# - AttachedToParent 任务混淆

Question

我无法理解 AttachedToParent 参数的工作原理。

示例代码如下:

public static void Main(string[] args)
    {
        Task<int[]> parentTask = Task.Run(()=> 
        {
            int[] results = new int[3];

            Task t1 = new Task(() => { Thread.Sleep(3000); results[0] = 0; }, TaskCreationOptions.AttachedToParent);
            Task t2 = new Task(() => { Thread.Sleep(3000); results[1] = 1; }, TaskCreationOptions.AttachedToParent);
            Task t3 = new Task(() => { Thread.Sleep(3000); results[2] = 2; }, TaskCreationOptions.AttachedToParent);

            t1.Start();
            t2.Start();
            t3.Start();

            return results;
        });

        Task finalTask = parentTask.ContinueWith(parent =>
        {
            foreach (int result in parent.Result)
            {
                Console.WriteLine(result);
            }
        });

        finalTask.Wait();
        Console.ReadLine();
    }

据我了解，当一个任务有子任务时，父任务会在所有子任务准备就绪时完成。这个例子的问题是输出看起来像这样:

0
0
0

这意味着父任务没有等待其子任务完成。获得有效结果 0 1 2 的唯一方法是在所有子 Tak 上使用 Wait，方法是在 return results; 语句之前添加一些这样的代码:

Task[] taskList = { t1, t2, t3 };
Task.WaitAll(taskList);

我的问题是这样的。当我们还必须为每个子任务手动调用 Wait 方法时，为什么我们要使用 TaskCreationOptions.AttachedToParent？

编辑:

在我写这个问题时，我稍微更改了代码，现在 AttachedToParent 运行良好。唯一的区别是我使用了 parentTask.Start(); 而不是 Task.Run();。

public static void Main(string[] args)
    {
        Task<int[]> parentTask = new Task<int[]>(()=> 
        {
            int[] results = new int[3];

            Task t1 = new Task(() => { Thread.Sleep(3000); results[0] = 0; }, TaskCreationOptions.AttachedToParent);
            Task t2 = new Task(() => { Thread.Sleep(3000); results[1] = 1; }, TaskCreationOptions.AttachedToParent);
            Task t3 = new Task(() => { Thread.Sleep(3000); results[2] = 2; }, TaskCreationOptions.AttachedToParent);

            t1.Start();
            t2.Start();
            t3.Start();

            //Task[] taskList = { t1, t2, t3 };
            //Task.WaitAll(taskList);

            return results;
        });

        parentTask.Start();

        Task finalTask = parentTask.ContinueWith(parent =>
        {
            foreach (int result in parent.Result)
            {
                Console.WriteLine(result);
            }
        });

        finalTask.Wait();
        Console.ReadLine();
    }

我还是不明白为什么第一个例子会有问题。

Answer 1

看看这篇博文:Task.Run vs Task.Factory.StartNew

第一个例子:

Task.Run(someAction);

是方法的简化等价物:

Task.Factory.StartNew(someAction,
         CancellationToken.None,
         TaskCreationOptions.DenyChildAttach,
         TaskScheduler.Default);

我做了一点研究，使用了反射器，这里是方法的来源 Task.Run

public static Task Run(Func<Task> function, CancellationToken cancellationToken)
    {
      if (function == null)
        throw new ArgumentNullException("function");
      cancellationToken.ThrowIfSourceDisposed();
      if (cancellationToken.IsCancellationRequested)
        return Task.FromCancellation(cancellationToken);
      else
        return (Task) new UnwrapPromise<VoidTaskResult>(
            (Task) Task<Task>.Factory.StartNew(function,
                                  cancellationToken, 
                                  TaskCreationOptions.DenyChildAttach,
                                  TaskScheduler.Default),
            true);
    }

方法Task.Factory.StartNew 的重要参数是TaskCreationOptions creationOptions。在方法 Task.Factory.StartNew 中，该参数等于 TaskCreationOptions.DenyChildAttach。这意味着

an InvalidOperationException will be thrown if an attempt is made to attach a child task to the created task

您需要更改为 TaskCreationOptions.None 以实现正确的代码行为。

方法 Task.Run 不提供更改 TaskCreationOptions 参数的能力。