为何Task.Run()有时无法实现任务并发执行？

核心原因 #

你的业务代码和测试用例（Thread.Sleep）的本质差异，加上Task启动时机的问题，导致并发失效：

1. 任务类型的本质区别 #

测试用例中的Thread.Sleep(1000)是阻塞型任务——线程会被挂起，不占用CPU资源。线程池可以立即调度另一个线程执行第二个Task，因此两个任务能真正并发，总耗时约1秒。

而你的业务代码里，CustomType.FromBinary(data)和字符串筛选处理是CPU密集型任务——线程会持续占用CPU。如果你的机器CPU核心数较少（比如单核），或者线程池没有足够空闲线程，第二个Task会被排队，等第一个Task释放CPU后才启动，总耗时自然等于两个任务的时间之和。

2. Task启动时机滞后 #

你的构造函数中，启动task1后，同步执行了CustomArchive arc2 = new(...)这个可能耗时的操作，导致task2的启动被延迟：

Task task1 = Task.Run(() => { /* 执行CPU密集操作 */ });
// 这段同步操作会占用主线程时间，task2要等它完成才会启动
CustomArchive arc2 = new CustomArchive("path/to/archive2");
Task<List<string>> task2 = Task.Run(() => { /* 执行CPU密集操作 */ });

如果创建arc2的时间刚好等于task1的执行时间，那么等task2启动时，task1已经完成，两个任务完全串行，总耗时就是450ms+350ms=800ms。

解决办法 #

1. 让两个Task同时启动 #

把所有准备工作（比如创建CustomArchive）放入Task内部，确保两个Task几乎同时启动：

public TestObject(string path)
{
    string arc1Path = "path/to/archive";
    string arc2Path = "path/to/archive2";

    // 同时启动两个包含准备工作的Task
    Task task1 = Task.Run(() =>
    {
        CustomArchive arc1 = new CustomArchive(arc1Path);
        foreach ((string name, byte[] data) in arc1.Files)
        {
            testDict[name] = CustomType.FromBinary(data);
        }
    });

    Task<List<string>> task2 = Task.Run(() => 
    {
        CustomArchive arc2 = new CustomArchive(arc2Path);
        return arc2.Files
            .Where(kvp => kvp.Key.Contains("SomeString"))
            .Select(kvp => System.Text.Encoding.UTF8.GetString(kvp.Value))
            .ToList();
    });

    // 等待所有任务完成，替代单独的Wait和Result
    Task.WhenAll(task1, task2).Wait();
    testStrings = task2.Result;
}

2. 优化CPU资源利用 #

如果任务是CPU密集型且机器核心数不足，优先优化任务的CPU效率（比如减少不必要的计算、使用更高效的解析库）；如果涉及磁盘/网络IO，改用异步IO操作（比如async/await配合异步IO方法），避免占用线程等待IO完成。

3. 调整线程池设置（谨慎使用） #

如果确定是线程池线程不足导致任务排队，可以在程序启动时临时调整线程池最小线程数：

// 根据机器核心数合理设置，不建议随意修改默认值
ThreadPool.SetMinThreads(Environment.ProcessorCount * 2, Environment.ProcessorCount * 2);

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