如何确保所有任务都已执行并查询最终结果

Question

我正在使用任务来执行计算密集型操作。 PerformCalculation 方法。主父任务使用任务工厂创建三个子任务并开始执行。每个子任务应返回 List<Dictionary<int,double>>

List<double> paramList = new List<double>{ 2, 2.5, 3};

CancellationTokenSource cts = new CancellationTokenSource();

Task parent = new Task(() =>
{
    var tf = new TaskFactory<List<Dictionary<int, double>>>(cts.Token, TaskCreationOptions.AttachedToParent,
    TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

    var childTasks = new[] {
        tf.StartNew(() => PerformCalculation(cts.Token, paramList[0],Task.CurrentId)),
        tf.StartNew(() => PerformCalculation(cts.Token, paramList[1],Task.CurrentId)),
        tf.StartNew(() => PerformCalculation(cts.Token, paramList[2],Task.CurrentId)) //3rd entry
        };

子任务执行成功后的结果应该是List<Dictionary<int, double>>的形式。

现在我的要求是编写一个 lambda 表达式，该表达式将在所有子任务完成执行后查询其结果并填充到另一个列表中

即列表列表 (List<List<Dictionary<int, double>>>)

// When all children are done, get the value returned from the
// non-faulting/canceled tasks. 
tf.ContinueWhenAll(childTasks, completedTasks => 
                   completedTasks
                   .Where(t => t.Status == TaskStatus.RanToCompletion)**??Need HELP HERE ???**),CancellationToken.None)
,TaskContinuationOptions.ExecuteSynchronously);

});

Answer 1

我会稍微回避一下这个问题，因为所有这些 API 基本上都已过时（或者至少不适合“主流”场景）。这实际上相当简单：

var childTasks = new[] {
    Task.Run(() => PerformCalculation(cts.Token, paramList[0],Task.CurrentId)),
    Task.Run(() => PerformCalculation(cts.Token, paramList[1],Task.CurrentId)),
    Task.Run(() => PerformCalculation(cts.Token, paramList[2],Task.CurrentId)),
    };

var results = Task.WhenAll(childTasks).Result;

TaskFactory 是一种相当深奥的类型，我从未见过在野外使用过。应避免附加子任务，因为它们添加了不明显的依赖关系。这些都不是错误，而是气味。