具有嵌套任务的 C# 代码比仅在顶层具有任务的相同代码运行速度慢

Question

我遇到了一个问题，即场景 1 的运行速度比场景 2 慢，尽管场景 1 似乎应该运行得更快，因为它不仅在更高级别打开任务，而且在内部级别打开任务。有点像父子概念（我知道父/子实际上并没有发生，因为我相信任务都在同一级别运行）。场景 2 只是在更高级别创建任务，并且整体运行速度更快。我能想到的唯一一件事是运行更少的任务会更快，因此可以并行处理所有内容，而不是尝试打开更多任务，这很可能会导致在 4 核（8 线程）CPU 上等待。

我想弄清楚场景 2 是否总是会更快，或者是否有更好的方法来编写场景 1，使其实际上比场景 2 更快。

场景 1（有嵌套任务）：

public void MainFunction() {
    IList<Task<ProductMaster>> tasks = new List<Task<ProductMaster>>();
    foreach (var x in products) 
    {
        Task<ProductMaster> prodMaster = Task.Factory.StartNew<ProductMaster>(() => RunProductMasterCode(param1, param2));

        tasks.Add(prodMaster);   
    }

    foreach (Task<ProductMaster> tsk in tasks)
    {
        ProductMaster prodMaster = tsk.Result;
        // COMPLEX CODE HERE THAT RELIES ON tsk.Result
    }
}

public ProductMaster RunProductMasterCode(int param1, int param2) {
    IList<Task<ProductSub>> tasks = new List<Task<ProductSub>>();
    foreach (var x in subProducts) 
    {
        Task<ProductSub> prodSub = Task.Factory.StartNew<ProductSub>(() => RunProductSubCode(param1));

        tasks.Add(prodSub);
    }

    foreach (Task<ProductSub> tsk in tasks)
    {
        ProductSub prodSub = tsk.Result;
        // COMPLEX CODE HERE THAT RELIES ON tsk.Result
    }
}

public ProductSub RunProductSubCode(int param1) {
    // COMPLEX CODE HERE
}

场景 2（有单层任务通知我没有在 RunProductMasterCode() 中创建任务）：

public void MainFunction() {
    IList<Task<ProductMaster>> tasks = new List<Task<ProductMaster>>();
    foreach (var x in products) 
    {
        Task<ProductMaster> prodMaster = Task.Factory.StartNew<ProductMaster>(() => RunProductMasterCode(param1, param2));

        tasks.Add(prodMaster);   
    }

    foreach (Task<ProductMaster> tsk in tasks)
    {
        ProductMaster prodMaster = tsk.Result;
        // COMPLEX CODE HERE THAT RELIES ON tsk.Result
    }
}

public ProductMaster RunProductMasterCode(int param1, int param2) {
    foreach (var x in subProducts) 
    {
        // NO THREADING HERE
        var prodSub = RunProductSubCode(param1);
    }
}

public ProductSub RunProductSubCode(int param1) {
    // COMPLEX CODE HERE
}

Answer 1

使用StartNew 创建一个任务只是为了立即等待结果是什么都不做，同时增加了构造任务、调度线程池上的工作、等待该线程池线程被调度，然后等待的开销以便在工作完成后再次安排原始线程。

让原始线程同步执行实际工作与构建您立即等待的任务具有相同的好处，而无需任何额外（相当昂贵的）开销。

如果您的所有代码实际上都需要完全同步运行，那么您根本不应该使用任何任务，只需运行代码即可。