未正确创建线程。非常简单的WaitAny c#

Question

我有一些非常简单的代码试图对现有脚本进行多线程处理。

在 Visual Studio 中检查履带窗口并调用 Thread.CurrentThread.ManagedThreadId 时，它始终报告为与启动进程相同的线程。结束时，它会报告一个不同的线程 ID。

线程似乎确实在异步执行任务，但是 Visual Studio 的日志记录和输出让我不这么认为。

请有人澄清发生了什么，如果我在我的方法中犯了错误？

namespace ResolveGoogleURLs
{
    class Program
    {
        public static void Main(string[] args)
        {
            HomeController oHC = new HomeController();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

namespace ResolveGoogleURLs
{
    class HomeController
    {
        public static int MaxJobs = 5;
        public static int RecordsPerJob = 1000;

        public static List<Task> TaskList = new List<Task>(MaxJobs);


        public HomeController()
        {
            CreateJobs();

            MonitorTasks();
        }


        public void MonitorTasks()
        {
            while (1 == 1)
            {
                Task.WaitAny(TaskList.ToArray());

                TaskList.RemoveAll(x => x.IsCompleted);

                Console.WriteLine("Task complete! Launching new...");
                CreateJobs();
            }
        }


        public async Task CreateJob()
        {
            Console.WriteLine("Thread {0} - Start", Thread.CurrentThread.ManagedThreadId);

            // read in results from sql

            await Task.Delay(10000);
            Console.WriteLine("Thread {0} - End", Thread.CurrentThread.ManagedThreadId);
        }


        public void CreateJobs()
        {
            while (TaskList.Count < MaxJobs)
            {
                TaskList.Add( CreateJob() );
            }
        }
    }
}

输出：

> Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Thread 4 - End
Thread 5 - End
Thread 4 - End
Thread 6 - End
Thread 8 - End
Task complete! Launching new...
Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Thread 7 - End
Thread 6 - End
Thread 5 - End
Thread 4 - End
Thread 8 - End
Task complete! Launching new...
Thread 1 - Start
Thread 1 - Start
Thread 1 - Start
Task complete! Launching new...
Thread 1 - Start
Thread 1 - Start
Thread 10 - End
Thread 9 - End
Task complete! Launching new...
Thread 1 - Start
Thread 7 - End
Thread 4 - End
Thread 6 - End
Task complete! Launching new...
Thread 1 - Start
Thread 1 - Start
Task complete! Launching new...
Thread 1 - Start
Thread 1 - Start

Answer 1

任务 (class Task) 与线程 (class Thread) 不同。

可以将线程想象成一个虚拟 CPU，它可以与其他线程同时运行其代码。每个线程都有自己的堆栈（存储局部变量和函数参数的地方）。在 .NET 中，线程被映射到本机线程 - 由平台（操作系统）支持，具有线程内核对象、内核模式堆栈、线程执行块等内容。这使得线程成为一个非常重量级的对象。创建新线程非常耗时，即使线程休眠（不执行其代码），它仍然会消耗大量内存（线程堆栈）。

操作系统会定期检查所有正在运行的线程，并根据它们的优先级为它们分配一个时隙，此时线程可以使用真正的 CPU（执行其代码）。

由于线程消耗内存，它们创建速度很慢，并且运行太多线程会损害整体系统性能，因此发明了任务（线程池）。

Task 在内部使用线程，因为线程是在 .NET 中并行运行代码的唯一方法。 （实际上这是运行任何代码的唯一方法。）但它以有效的方式执行。

当一个 .NET 进程启动时，它会在内部创建一个线程池 - 一个用于执行任务的线程池。

任务库是这样实现的，当一个进程启动时，一个线程池只包含一个线程。如果您开始创建新任务，它们将被存储到一个队列中，该单个线程从该队列中获取并执行一个又一个任务。但是 .NET 会监视该线程是否没有因太多任务而超载 - 任务在线程池队列中等待“太久”的情况。如果 - 基于其内部标准 - 它检测到最初创建的线程过载，它会创建一个新线程。所以线程池现在有 2 个线程，任务可以在其中 2 个线程上并行运行。这个过程可以重复，所以如果负载很重，线程池可以有 3、4 或更多线程。

另一方面，如果新任务的频率下降，并且线程池线程没有任务要执行，则在“一段时间”之后（“一段时间”是由内部线程池标准定义的）线程池可以决定释放一些线程——以节省系统资源。线程池线程数可以下拉到最初创建的单线程。

所以任务库内部使用线程，但它试图以有效的方式使用它们。线程数根据程序要执行的任务数来增加和减少。

在几乎所有情况下，任务都应该是使用“原始”线程的首选解决方案。