ThreadPool.QueueUserWorkItem 与 Task.Factory.StartNew

Question

下面

ThreadPool.QueueUserWorkItem

和

Task.Factory.StartNew

如果上面的代码对于某个长时间运行的任务被调用 500 次，是否意味着所有线程池线程都将被占用？

或者 TPL（第二个选项）是否足够聪明，只占用少于或等于处理器数量的线程？

Answer 1

如果要使用 TPL 启动长时间运行的任务，则应指定 TaskCreationOptions.LongRunning，这意味着它不会将其调度到线程池上。 （编辑：正如评论中所指出的，这是一个特定于调度程序的决定，并不是一个硬性和快速的保证，但我希望任何明智的生产调度程序都会避免调度长时间运行的任务在线程池上。）

您绝对不应该自己在线程池上安排大量长时间运行的任务。我相信现在线程池的默认大小相当大（因为它经常以这种方式被滥用），但从根本上讲，它不应该这样使用。

线程池的目的是避免短任务因创建新线程而受到与实际运行时间相比的较大影响。如果任务将运行很长时间，那么创建新线程的影响无论如何都会相对较小 - 并且您不希望最终可能耗尽线程池线程。 （现在不太可能，但我确实在早期版本的.NET 上经历过这种情况。）

就我个人而言，如果可以选择，我肯定会使用 TPL，因为 Task API 非常好 - 但一定记得告诉 TPL 您希望任务运行很长时间。

编辑：如评论中所述，另请参阅 PFX 团队的博客文章 在 TPL 和线程池之间进行选择：

最后，我将重申 CLR 团队的 ThreadPool 开发人员已经说过的话：

任务现在是将工作排队到线程池的首选方式。

编辑：同样从评论中，不要忘记 TPL 允许您使用 自定义调度程序，如果你真的想...

Answer 2

不，ThreadPool 线程通过使用 Task.Factory.StartNew 方法（或更现代的 Task.Run 方法）。调用 Task.Factory.StartNew 500 次（对于长时间运行的任务）肯定会使 ThreadPool 饱和，并且会使其在很长一段时间内保持饱和。这不是一个好的情况，因为饱和的线程池会对在此 500 个启动任务期间也可能处于活动状态的任何其他独立回调、计时器事件、异步延续等产生负面影响。

Task.Factory.StartNew 方法安排在 TaskScheduler.Current，默认为 TaskScheduler.Default，这是内部 ThreadPoolTask​​Scheduler 类。这是 的实现>ThreadPoolTask​​Scheduler.QueueTask方法：

protected internal override void QueueTask(Task task)
{
    if ((task.Options & TaskCreationOptions.LongRunning) != 0)
    {
        // Run LongRunning tasks on their own dedicated thread.
        Thread thread = new Thread(s_longRunningThreadWork);
        thread.IsBackground = true; // Keep this thread from blocking process shutdown
        thread.Start(task);
    }
    else
    {
        // Normal handling for non-LongRunning tasks.
        bool forceToGlobalQueue = ((task.Options & TaskCreationOptions.PreferFairness) != 0);
        ThreadPool.UnsafeQueueCustomWorkItem(task, forceToGlobalQueue);
    }
}

可以看到任务的执行被调度在无论如何，线程池。 ThreadPool.UnsafeQueueCustomWorkItem 是 ThreadPool 类的一个内部方法，并且有一些细微差别（bool forceGlobal））未公开暴露。但是，当线程池饱和时，它不会改变它的行为。目前，这种行为也不是特别复杂。线程注入算法只是每 1000 毫秒向池中注入一个新线程，直到饱和事件结束。

1 _{当工作需求超过线程的当前可用性时，ThreadPool 被称为饱和，并且阈值SetMinThreads 已达到，超过该值不再按需创建新线程。}