当我不使用 TaskCreationOptions.LongRunning 时出现奇怪的行为

Question

我有一个引擎，它有任意数量的轮询器，每个轮询器每隔几秒进行一次“轮询”。我希望轮询器在不同的线程中运行，但单个轮询器中的每个“轮询”应该是连续的，以便一个轮询发生在下一个轮询之后。使用此代码启动轮询过程一切正常：

    public void StartPolling()
    {
        Stopwatch watch = new Stopwatch();
        while (Engine.IsRunning)
        {
            Task task = Task.Factory.StartNew(() =>{
                watch.Restart();
                Poll();
                watch.Stop();
            },TaskCreationOptions.LongRunning);
            task.Wait();
            if(Frequency > watch.Elapsed) Thread.Sleep(Frequency - watch.Elapsed);
        }
    }

但是，我花了一段时间才发现 TaskCreationOptions.LongRunning 选项解决了我遇到的一个我仍然不明白的奇怪问题。 如果没有该选项，如果我运行创建 1-3 个轮询器的测试，则一切正常。如果我创建了 4+ 然后我会遇到奇怪的行为。三个轮询器可以工作，一个只能执行一项轮询，其余的则根本不会进行轮询。 我的任务是长期运行的，这是完全有道理的。毕竟他们正在运行我的程序的整个长度。但我不明白为什么如果没有设置此选项，我会出现一些不良行为。任何帮助将不胜感激。

Answer 1

当您不使用 LongRunning 标志时，任务将安排在线程池线程上，而不是其自己的（专用）线程上。这可能是导致您的行为发生变化的原因 - 当您在没有设置 LongRunning 标志的情况下运行时，您可能会由于进程中的其他线程而导致线程池匮乏。

话虽这么说，你上面的代码并没有多大意义。您正在启动一个专用线程（通过 Task....StartNew 和 LongRunning）来启动任务，然后立即调用 task.Wait()，这会阻塞当前线程。最好在当前线程中按顺序执行此操作：

public void StartPolling()
{
    Stopwatch watch = new Stopwatch();
    while (Engine.IsRunning)
    {
        watch.Restart();
        Poll();
        watch.Stop();
        if(Frequency > watch.Elapsed) Thread.Sleep(Frequency - watch.Elapsed);
    }
}

Answer 2

TPL（和传统的ThreadPool）限制池中的线程数量（通常是CPU核心数量的一小部分，通常是2x核心）。如果您将任务标记为“LongRunning”，它就知道该任务不会很快完成，并且可能不会使该任务受到线程限制。

如果没有 LongRunning，它会假设您的任务将很快完成（但事实并非如此），因此它保持在线程限制内。然后，如果您创建的任务多于线程限制，并且正在运行的任务永远不会结束，TPL 会停止所有其他任务的运行，徒劳地等待这些正在运行的任务完成（它们永远不会这样做）。