如何聚合多个任务结果

本文关键字：任务 结果 何聚 | 更新日期: 2023-09-27 18:07:47

我在下面的代码片段中创建了2个任务，现在我想把这两个任务的结果合并到一个变量中:

public class DataPoint
{
    public int Id { get; set; }
    public string Data { get; set; }
}
public class Worker
{
    public void DoProcessing()
    {
        List<DataPoint> dp = new List<DataPoint>();
        Task task1 = Task.Factory.StartNew(() => Process1(dp));
        Task task2 = Task.Factory.StartNew(() => Process2(dp));
        Task.WhenAll(task1, task2);
        //var finalResult = task1 result + Task 2 results
    }
    private List<DataPoint> Process1(List<DataPoint> dp1)
    {
        return dp1;
    }
    private List<DataPoint> Process2(List<DataPoint> dp2)
    {
        return dp2;
    }
}

如何聚合多个任务结果

如果你想要连接这两个列表，你首先需要将你的方法标记为async Task，然后标记为await Task.WhenAll，以便异步等待两个任务完成:

public async Task DoProcessingAsync()
{
    var task1 = Task.Run(Process1);
    var task2 = Task.Run(Process2);
    var result = await Task.WhenAll(task1, task2);
    var finalResult = task1.Result.Concat(task2.Result).ToList();
}
private List<DataPoint> Process1()
{
    return new List<DataPoint>();
}
private List<DataPoint> Process2()
{
    return new List<DataPoint>();
}

如果你使用。net 4.5或更高版本，请选择Task.Run而不是Task.Factory.StartNew。

另外，List<T>不是线程安全的，不要在任务中传递由ProcessX方法返回的列表。使每个返回一个新的List<DataPoint>，这样你就不会有线程问题。

这可以进一步简化为await Task.WhenAll聚合结果:-

Task<int> t1 = Task.Factory.StartNew(() => { return 1; });
Task<int> t2 = Task.Factory.StartNew(() => { return 2; });
var result = await Task.WhenAll(t1, t2);
// result
// int[2] { 1, 2 }
相关文章：