.NET中提升任务优先级及高效记录任务进度的方法

这个问题我之前也碰到过！当你启动大量CPU密集型的DoWork任务时，线程池会优先把资源倾斜给这些任务，导致你的进度记录任务被“饿死”——任务数量越多，它越难抢到CPU时间片，只能等其他任务快结束时才能跑起来。另外你之前用Stopwatch做忙等待循环的方式也会雪上加霜，它一直在占用CPU检查时间，反而和其他任务抢资源，拖慢整体性能。

给你两个靠谱的解决方案，按优先级推荐：

方案1：用异步非忙等待替代忙循环（最推荐） #

把进度记录改成异步方法，用Task.Delay()代替Stopwatch的循环检查。Task.Delay()是异步等待，会把线程还给线程池，不会一直占用CPU，这样进度任务既能按时触发，又不会影响其他任务的执行。

修改后的代码示例：

// 改成async Task异步方法
public async Task RecordProgressAsync()
{
    while (_processing)
    {
        Console.WriteLine($"已生成 {_docsGenerated} 份文档");
        // 等待指定时间，期间线程会被放回线程池，不占用CPU
        await Task.Delay(_logFrequency); 
    }
}

public void GenerateDocs()
{
    List<Task> tasks = new List<Task>();
    _processing = true;
    _docsGenerated = 0; // 初始化进度
    
    // 启动所有文档生成任务
    for (int i = 0; i < 50; i++)
    {
        tasks.Add(Task.Run(() => DoWork()));
    }
    
    // 启动进度记录任务（无需额外Task.Run，直接调用异步方法）
    var progressTask = RecordProgressAsync();
    
    // 等待所有生成任务完成
    Task.WaitAll(tasks.ToArray());
    
    // 通知进度任务停止
    _processing = false;
    // 等待进度任务彻底结束
    progressTask.Wait();
}

// 关键：_docsGenerated的修改必须保证线程安全！
private void DoWork()
{
    // 假设每个任务生成N份文档
    for (int j = 0; j < 2000; j++)
    {
        // 生成TXT文档的逻辑...
        
        // 用Interlocked保证多线程下计数准确，避免竞争条件
        Interlocked.Increment(ref _docsGenerated);
    }
}

这个方案的优势：

• 完全避免忙等待，CPU占用率会大幅降低
• 异步等待不会抢占其他任务的资源，进度任务能按时触发
• 代码简洁，符合Task异步编程的最佳实践

方案2：用独立线程+提升优先级（针对极端CPU密集场景） #

如果你的DoWork是非常消耗CPU的任务（比如大量计算），线程池可能还是会优先调度这些任务，导致进度任务的异步等待被延迟。这时候可以给进度记录单独开一个线程，并且提升它的优先级，让操作系统优先调度它。

代码示例：

public void RecordProgress()
{
    while (_processing)
    {
        Console.WriteLine($"已生成 {_docsGenerated} 份文档");
        // Sleep会让出CPU，不会做无意义的循环等待
        Thread.Sleep(_logFrequency);
    }
}

public void GenerateDocs()
{
    List<Task> tasks = new List<Task>();
    _processing = true;
    _docsGenerated = 0;
    
    for (int i = 0; i < 50; i++)
    {
        tasks.Add(Task.Run(() => DoWork()));
    }
    
    // 创建独立线程，设置高于正常的优先级
    var progressThread = new Thread(RecordProgress)
    {
        Priority = ThreadPriority.AboveNormal,
        IsBackground = true // 后台线程，程序退出时自动终止
    };
    progressThread.Start();
    
    Task.WaitAll(tasks.ToArray());
    
    // 停止进度线程
    _processing = false;
    progressThread.Join(); // 等待线程完全结束
}

// 同样要保证进度计数的线程安全
private void DoWork()
{
    for (int j = 0; j < 2000; j++)
    {
        // 生成文档逻辑...
        Interlocked.Increment(ref _docsGenerated);
    }
}

这个方案的优势：

• 独立线程不受线程池调度策略的影响，提升优先级后能确保被及时调度
• Thread.Sleep()同样不会占用CPU资源

注意：不要随便把线程优先级设得太高（比如Highest），否则可能会影响其他系统进程的运行，AboveNormal足够满足需求。

关键注意点 #

1. 线程安全的进度计数：_docsGenerated是多个任务同时修改的变量，必须用Interlocked类或者lock来保证线程安全，否则会出现计数错误（比如多个任务同时++导致数值不递增）。
2. 绝对避免忙等待：不管用哪种方案，都不要用Stopwatch循环检查时间的方式，这种忙等待会持续占用CPU，拖慢整个程序。

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