如何为Kestrel分配更高优先级以保障.NET Core应用响应性？

当Kestrel承载的Web应用与耗CPU的后台逻辑同属一个进程时，CPU占满会导致Web请求响应延迟，无需拆分进程，可通过以下方案优化资源调度优先级。

核心思路 #

通过降低后台任务的线程优先级或隔离CPU资源，让操作系统优先分配CPU时间给Kestrel的工作线程，从而保证Web请求的响应速度。

具体实现方案 #

1. 给后台任务设置低优先级线程 #

Kestrel的工作线程默认使用ThreadPriority.Normal，将耗CPU的后台任务放到优先级更低的线程中，系统会优先调度Kestrel线程。

修改原代码，用Thread替代Task.Run手动控制线程优先级：

namespace WebApplication1
{
    public class Program
    {
        public static void CpuIntensiveWork()
        {
            for (int i = 0; i < int.MaxValue; i++)
            {
                for (int x = 0; x < int.MaxValue; x++)
                {
                }
            }
        }

        public static void Main(string[] args)
        {
            var builder = WebApplication.CreateBuilder(args);
            var app = builder.Build();

            app.MapGet("/", () => 
            {
                var workerThread = new Thread(CpuIntensiveWork)
                {
                    Priority = ThreadPriority.BelowNormal, // 设为低于正常优先级
                    IsBackground = true // 后台线程，进程退出时自动终止
                };
                workerThread.Start();
                return "Hello World!"; 
            });

            app.Run();
        }
    }
}

2. 使用自定义低优先级任务调度器 #

如果习惯用Task异步编程模型，可以实现自定义任务调度器，让所有后台任务统一使用低优先级线程池：

public class LowPriorityTaskScheduler : TaskScheduler
{
    private readonly ThreadPoolExecutor _executor;

    public LowPriorityTaskScheduler(int threadCount = 4)
    {
        _executor = new ThreadPoolExecutor(threadCount, ThreadPriority.BelowNormal);
    }

    protected override IEnumerable<Task> GetScheduledTasks() => Enumerable.Empty<Task>();

    protected override void QueueTask(Task task)
    {
        _executor.Execute(() => TryExecuteTask(task));
    }

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

    private class ThreadPoolExecutor
    {
        private readonly BlockingCollection<Action> _queue = new();

        public ThreadPoolExecutor(int threadCount, ThreadPriority priority)
        {
            for (int i = 0; i < threadCount; i++)
            {
                var thread = new Thread(() =>
                {
                    foreach (var action in _queue.GetConsumingEnumerable())
                    {
                        action();
                    }
                })
                {
                    Priority = priority,
                    IsBackground = true
                };
                thread.Start();
            }
        }

        public void Execute(Action action) => _queue.Add(action);
    }
}

使用方式：

// 在Program中初始化调度器
var lowPriorityScheduler = new LowPriorityTaskScheduler();

app.MapGet("/", () => 
{
    Task.Factory.StartNew(CpuIntensiveWork, CancellationToken.None, TaskCreationOptions.None, lowPriorityScheduler);
    return "Hello World!"; 
});

3. CPU亲和性隔离（多核服务器适用） #

如果服务器是多核CPU，可以将Kestrel线程和后台任务线程绑定到不同的CPU核心，实现物理上的CPU资源隔离：

public static void Main(string[] args)
{
    var currentProcess = Process.GetCurrentProcess();
    // 假设服务器有4个核心，将Kestrel绑定到0、1核心，后台任务用2、3核心
    currentProcess.ProcessorAffinity = new IntPtr(0b0011); 

    var builder = WebApplication.CreateBuilder(args);
    var app = builder.Build();

    app.MapGet("/", () => 
    {
        var workerThread = new Thread(CpuIntensiveWork)
        {
            IsBackground = true
        };
        // 给后台线程单独设置亲和性，绑定到2、3核心
        workerThread.ProcessorAffinity = new IntPtr(0b1100);
        workerThread.Start();
        return "Hello World!"; 
    });

    app.Run();
}

关键注意事项 #

• 线程优先级是系统调度的提示而非强制规则，极端高负载下仍可能有影响，但能显著缓解请求延迟问题。
• 避免无限制创建后台线程：每次请求启动新线程会导致线程爆炸，建议用线程池或固定数量的工作线程处理后台任务。
• 后台任务设为IsBackground = true：确保进程退出时后台线程自动终止，避免阻塞进程关闭。

内容的提问来源于stack exchange，提问作者mayen