У меня проблема с пониманием того, как работает параметр 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
- использовать Wait для всех дочерних Taks, добавив некоторые фрагменты кода, подобные этому, перед оператором return results;
:
Task[] taskList = { t1, t2, t3 };
Task.WaitAll(taskList);
Мой вопрос в том, что. Почему мы используем TaskCreationOptions.AttachedToParent
, когда нам также нужно вручную вызвать метод Wait для каждой дочерней задачи?
Edit:
Пока я писал этот вопрос, я немного изменил код, и теперь 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();
}
Я до сих пор не понимаю, почему возникает проблема с первым примером.