C# 并行执行线程限制

Question

我正在编写一个简单的测试，它只记录并发请求开始的时间，然后休眠一秒钟。

static void TestParallelism()
{
    int expectedThreadCount = 100;
    ThreadPool.SetMaxThreads(Environment.CurrentManagedThreadId, expectedThreadCount);
    var module = new WCFCompositeModule();
    module.Initialize(new Keywords());

    var range = Enumerable.Range(0, expectedThreadCount);
    var startTimes = new ConcurrentBag<DateTime>();

    var parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = expectedThreadCount };
    Parallel.ForEach(range, i =>
    {
        startTimes.Add(DateTime.Now);
        Thread.Sleep(1000);
    });

    foreach (var time in startTimes)
    {
        Console.WriteLine(string.Format("{0: HH:mm:ss.fff}", time));
    }

    Console.ReadLine();
}

当我使用 100 个预期线程执行此操作时，我可以看到 12 个不同的不同开始时间，所有时间都相差 1 秒。而不是看到它们都在同一秒开始。

样本

13:59:27.475 13:59:26.473 13:59:25.473 13:59:24.471 13:59:23.470 13:59:22.469

这是因为 sleep 阻塞了线程吗？

Answer 1

您似乎希望这段代码启动 100 个线程，但是

MaxDegreeOfParallelism = expectedThreadCount 

仅设置最大值，而不是最小值，系统会将其分派给任意数量（最多为 MaxDegreeOfParallelism）的线程。

除非您有一台 100 核机器，否则它不太可能用完 100 个线程，因此它使用 X 线程，然后它们都阻塞 1 秒钟，然后在相同的先前 X 线程上调度下一批。这里 x 是 100/12 = 8.333333，所以如果你看到 12 个不同的时间，它会启动至少 12 个不同的批次，这意味着它一次执行 8 到 9 个线程，如果你有一个具有超线程的 4 核系统或 8核心系统这可能是默认行为。