非异步方法超时包装器在循环大量调用时表现异常

你遇到的随机超时和总耗时增加问题，核心原因是线程池饥饿。具体分析如下：

• Parallel.For是基于线程池的同步并行框架，本身会占用线程池线程；你在BigWorker里又用Task.Run提交阻塞式的SlowWorker任务，相当于在每个并行任务中再向线程池请求新线程。
• 线程池默认的扩容规则是每秒新增一个线程，当任务量（比如100个）远大于初始线程数时，大量Task.Run的任务会进入等待队列。此时TimeoutAfter里的Task.Delay已经开始计时，但实际的SlowWorker还没被调度执行，最终触发不该有的超时。

下面是针对性的解决方案：

方案1：改用异步并行替代Parallel.For #

既然BigWorker是异步方法，没必要用同步的Parallel.For，改用Task.WhenAll实现异步并行，能更高效地调度线程：

// 替换Parallel.For的调用逻辑
var tasks = Enumerable.Range(0, 100).Select(i => BigWorker(i));
await Task.WhenAll(tasks);

异步并行会让线程池线程在等待await时及时释放，处理其他任务，避免线程被长时间阻塞占用，从根源缓解线程池饥饿问题。

方案2：调整线程池最小线程数（临时应急） #

如果必须保留Parallel.For，可以临时提高线程池最小工作线程数，跳过扩容延迟，让线程池一开始就有足够线程处理任务：

// 在Parallel.For执行前修改线程池设置
int originalWorkerThreads, originalIoThreads;
ThreadPool.GetMinThreads(out originalWorkerThreads, out originalIoThreads);
ThreadPool.SetMinThreads(Math.Max(originalWorkerThreads, 100), originalIoThreads);

try
{
    Parallel.For(0, 100, i => BigWorker(i).Wait());
}
finally
{
    // 可选：恢复线程池原设置，避免影响其他业务
    ThreadPool.SetMinThreads(originalWorkerThreads, originalIoThreads);
}

注意：这种方法需要预估任务量，硬编码线程数不够灵活，仅适合临时场景。

方案3：限制并发度避免过载 #

不管用哪种并行方式，都可以通过信号量限制同时执行的任务数，防止线程池资源耗尽：

// 限制同时最多20个任务执行
var semaphore = new SemaphoreSlim(20);
var tasks = Enumerable.Range(0, 100).Select(async i =>
{
    await semaphore.WaitAsync();
    try
    {
        return await BigWorker(i);
    }
    finally
    {
        semaphore.Release();
    }
});
await Task.WhenAll(tasks);

合理的并发度能平衡任务执行效率和线程池资源占用，避免因任务过载导致的调度延迟。

优化TimeoutAfter扩展方法 #

你的现有扩展方法中，CancellationTokenSource没有实际关联到任务，取消操作无效。可以优化代码，同时提升性能：

static class Extensions
{
    public static async Task<T> TimeoutAfter<T>(this Task<T> task, TimeSpan timeout)
    {
        using var cts = CancellationTokenSource.CreateLinkedTokenSource(default);
        var delayTask = Task.Delay(timeout, cts.Token);
        
        var completedTask = await Task.WhenAny(task, delayTask).ConfigureAwait(false);
        if (completedTask == delayTask)
        {
            throw new TimeoutException("操作超时");
        }
        
        cts.Cancel(); // 取消未完成的延迟任务，释放资源
        return await task.ConfigureAwait(false);
    }
}

添加ConfigureAwait(false)避免不必要的上下文切换，用using自动释放CancellationTokenSource，代码更健壮。

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