c# - 使用Task.WaitAll(threads)没有适当地阻止

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Threads
{
    class Program
    {
        static void Main(string[] args)
        {
            Action<int> TestingDelegate = (x321) => { Console.WriteLine(x321); };
            int x123 = Environment.ProcessorCount;

            MyParallelFor(0, 8, TestingDelegate);
            Console.Read();
        }

        public static void MyParallelFor(int inclusiveLowerBound, int exclusiveUpperBound, Action<int> body)
        {

            int size = exclusiveUpperBound - inclusiveLowerBound;
            int numProcs = Environment.ProcessorCount;
            int range = size / numProcs;

            var threads = new List<Task>(numProcs);
            for(int p = 0; p < numProcs; p++)
            {
                int start = p * range + inclusiveLowerBound;
                int end = (p == numProcs - 1) ? exclusiveUpperBound : start + range;
                Task.Factory.StartNew(() =>
                {
                    for (int i = start; i < end; i++) body(i);
                });

            }

            Task.WaitAll(threads.ToArray());
            Console.WriteLine("Done!");
        }
    }
}

大家好，我实现了《并行编程模式》一书中的这段代码，它们使用线程来完成，因此我决定使用TPL库对其进行重写。下面的输出是我得到的（当然是随机的），但是...我希望“完成！”总是最后打印。由于某种原因，它没有这样做。为什么不阻塞？

Done!
1
0
2
6
5
4
3
7

最佳答案

您没有将任何任务分配给要在其上调用WaitAll的threads列表，您的任务是独立启动的。您将创建任务并将任务放入threads集合，然后再调用WaitAll。您可以找到更多如何将任务添加到在此MSDN文档中为Task.WaitAll Method (Task[])创建的任务列表中的方法。

您的代码将类似于

threads.Add(Task.Factory.StartNew(() =>
{
    for (int i = 0; i < 10; i++) ;
}));