了解 .NET 的默认 TaskScheduler 和线程池(ThreadPool)设置,避免让 Task.Run 的性能急剧降低


.NET Framework 4.5 开始引入 Task.Run,它可以很方便的帮助我们使用 async / await 语法,同时还使用线程池来帮助我们管理线程。以至于我们编写异步代码可以像编写同步代码一样方便。

不过,如果滥用,也可能导致应用的性能急剧下降。本文将说明在默认线程池配置(ThreadPoolTaskScheduler)的情况下,应该如何使用 Task.Run 来避免性能的急剧降低。


本文内容

      • 如何使用 Task.Run?
      • 示例程序和示例代码
      • TaskScheduler
      • ThreadPool
      • 推荐的使用方法
        • 参考资料

ThreadPoolTaskScheduler.QueueTask。

于是,你在线程池中的设置将决定一个 Task 将在何时开启一个线程执行。

ThreadPool.GetMinThreads(Int32, Int32) Method (System.Threading) - Microsoft Docs

  • 线程池按需提供新的工作线程或 I/O 完成线程直到它达到每个类别的最小值。
  • 默认情况下,最小线程数设置为在系统上的处理器数。
  • 当达到最小值时,线程池可以创建该类别中的其他线程或等待,直到一些任务完成。
  • 需求较低时,线程池线程的实际数量可以低于最小值。

于是便会出现我们在本文一开始运行时出现的结果图。在我的计算机上(八核),最小线程数是 8,于是开始的 8 个任务可以立即开始执行。当达到数量 8 而依然没有线程完成执行的时候,线程池会尝试等待任务完成。但是,1 秒后依然没有任务完成,于是线程池创建了一个新的线程来执行新的任务;接下来是每隔一秒会开启一个新的线程来执行现有任务。当有任务完成之后,就可以直接使用之前完成了任务的线程继续完成新的任务。

不过,每个类别创建线程的总数量受到最大线程数限制。

TaskScheduler Class (System.Threading.Tasks) - Microsoft Docs
  • TaskCreationOptions Enum (System.Threading.Tasks) - Microsoft Docs
  • Parallel Tasks - Microsoft Docs
  • Attached and Detached Child Tasks - Microsoft Docs
  • 在 ThreadPool.GetMinThreads(Int32, Int32) Method (System.Threading) - Microsoft Docs
  • Managed Threading Best Practices - Microsoft Docs