ASP.NET Core 6中使用TaskScheduler限制线程数失效问题

你的方案失效核心原因是自定义TaskScheduler无法有效控制异步任务的并发：

1. 调用Task.Factory.StartNew(() => ProcessFile(...))时，ProcessFile是异步方法，StartNew会立即返回一个Task<Task>（外层任务）；当ProcessFile执行到第一个await时，外层任务就会标记为完成，自定义调度器会立刻调度下一个任务，导致并发数超出限制。
2. 即使对返回的任务调用Unwrap()，异步任务在await完成后的延续代码会回到ASP.NET Core默认的无上下文调度器（即线程池），不受自定义调度器的约束。

对于CPU/内存密集型的异步任务，SemaphoreSlim是更简单可靠的并发控制方式，直接限制同时执行的任务数量：

1. 注册单例信号量 #

在Program.cs中注册一个初始计数为2的SemaphoreSlim（允许同时处理2个文件）：

builder.Services.AddSingleton<SemaphoreSlim>(_ => new SemaphoreSlim(2, 2));

2. 修改任务启动逻辑 #

在上传服务中注入信号量，启动处理任务时通过信号量控制并发：

public class FileUploadService
{
    private readonly SemaphoreSlim _concurrencySemaphore;

    // 构造函数注入信号量
    public FileUploadService(SemaphoreSlim concurrencySemaphore)
    {
        _concurrencySemaphore = concurrencySemaphore;
    }

    public async Task UploadFile(Stream stream, string filePath, ...)
    {
        // 完成文件上传到磁盘的逻辑
        await SaveStreamToFileAsync(stream, filePath);

        // 启动后台处理任务，用信号量限制并发
        _ = Task.Run(async () =>
        {
            await _concurrencySemaphore.WaitAsync();
            try
            {
                await ProcessFile(filePath, ...);
            }
            finally
            {
                // 无论成功失败都释放信号量，避免死锁
                _concurrencySemaphore.Release();
            }
        });
    }

    private async Task SaveStreamToFileAsync(Stream stream, string filePath)
    {
        // 文件保存逻辑实现
    }

    public async Task ProcessFile(string filePath, ...)
    {
        var stage1 = await ProcessStage1(...);
        var stage2 = await ProcessStage2(...);
        await SendEmail(...);
    }
}

如果必须用自定义调度器，需要将异步任务包装成不释放线程的同步任务，但这种方式会阻塞调度器线程，违背异步设计的初衷，仅作参考：

// 用TaskFactory启动任务，并同步等待异步流程完成
await _processFileFactory.Factory.StartNew(() => ProcessFile(filePath, ...).GetAwaiter().GetResult());

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