当我需要可扩展性时，我应该不使用 TPL 吗？

Question

线程池线程是重要的可重用线程（例如在 asp.net 中）- 有助于处理请求。

相对于原语new Thread().start(....)，它不使用线程池线程，并且不支持取消标记、连续性、结果值——毫无疑问，TPL 是首选策略。

但问题是Task 也是 uses 线程池线程。

在 TPL 中，TaskScheduler 负责实际对任务进行排队 准备执行。默认调度程序将使用线程池。

这让我想知道：

假设我有一个有许多并发用户的站点，我需要为每个用户执行 3 个计算绑定任务（非 IO）。

我担心线程池将没有线程剩余（因为我将通过使用线程池线程的 TASK 执行 3 个计算操作（针对每个用户）。 - 这将导致创建新的线程池线程。

这使我得出结论，当我需要可扩展性时 - 最好使用旧时尚 new Thread().start(...) ？

我错过了什么？我们回到原点了吗？

Answer 1

您很少需要在 ASP.NET 中使用 Task.Run 或 Task.Factory.StartNew。这些 API 用于 CPU 密集型工作，在处理 HTTP 请求时将 CPU 密集型工作卸载到另一个线程通常没有意义（与客户端 UI 应用程序不同）。那只会损害可扩展性。只需在当前线程上执行工作即可。

如果您需要跨多个 HTTP 请求生成具有生命周期的长期运行任务，请使用 cmets 中 @Damien_The_Unbeliever 建议的单独进程，例如，在同一主机或单独主机上的 WCF 服务。

也就是说，您仍然可以将一个非池线程包装为 Task 以及所有好东西，至少在当前的 TPL 实现中是这样。它是在您使用 TaskCreationOptions.LongRunning 和 Task.Factory.StartNew 时创建的。在这样的线程中，Thread.IsThreadPoolThread 将是 false。这可以防止ThreadPool 饥饿，但肯定会增加进程的工作集。此外，此类线程不会像ThreadPool 线程那样被 TPL 重用，因此重复创建非池线程可能会非常昂贵。

作为TaskCreationOptions.LongRunning 的替代方案，使用TaskCompletionSource 可以轻松地将new Thread().Start() 包装为Task，具有相同的取消、异常和结果传播逻辑。

另一个想法是使用自定义任务调度程序，它总是将任务排入新线程：

class Program
{
    static void Main(string[] args)
    {
        Console.WriteLine(new { Thread.CurrentThread.ManagedThreadId });

        var task = Task.Factory.StartNew(
            () => Console.WriteLine(new { 
                Thread.CurrentThread.IsThreadPoolThread,
                Thread.CurrentThread.ManagedThreadId}),
            CancellationToken.None,
            // hide the scheduler from inner tasks
            TaskCreationOptions.HideScheduler,
            NewThreadTaskScheduler.Scheduler);

        task.Wait();
    }
}

class NewThreadTaskScheduler : TaskScheduler
{
    public static readonly NewThreadTaskScheduler Scheduler = 
        new NewThreadTaskScheduler();

    NewThreadTaskScheduler()
    {
    }

    protected override void QueueTask(Task task)
    {
        var thread = new Thread(() =>
        {
            base.TryExecuteTask(task);
        });
        thread.IsBackground = true;
        thread.Start();
    }

    protected override bool TryExecuteTaskInline(
        Task task, 
        bool taskWasPreviouslyQueued)
    {
        return false;
    }

    protected override IEnumerable<Task> GetScheduledTasks()
    {
        return null;
    }

    public override int MaximumConcurrencyLevel { 
        get { return Int32.MaxValue; } }
}