具有 MaxDegreeOfParallelism 和实际线程数的 ParallelOptions

Question

您好，我正在使用 MaxDegreeOfParallelism 方法的不同值进行“动态”多线程处理，但是每当我尝试更改大于 1 的 MaxDegreeOfParallelism 的值时，它会在控制台中显示该程序使用的线程数超过了我分配的线程数。

public static string DoMultipleTasks(int threads, List<string> inputList)
{            
    ParallelOptions po = new ParallelOptions();          
    po.MaxDegreeOfParallelism = threads;
    Parallel.ForEach(inputList, po,  values =>
    {
        Console.WriteLine(" Name: {0}, Thread Id= {1}", values, Thread.CurrentThread.ManagedThreadId);
    });            
    return null;
}

输出：

Answer 1

MaxDegreeOfParallelism 指定可以同时运行多少个线程（或者更确切地说是任务）。它没有指定应该是哪些线程。

来自docs：

获取或设置此 ParallelOptions 实例启用的最大并发任务数。

在您执行Parallel.ForEach 期间，您可能会在许多不同的线程上运行（因此涉及许多不同的线程ID）。这取决于底层线程调度程序。

但是，您可以保证您的代码块最多同时执行MaxDegreeOfParallelism。

虽然您基本上已经有了一个示例，但这里有一个稍微修改过的代码版本来说明我的意思。

var dict = new ConcurrentDictionary<int, string>();
var po = new ParallelOptions { MaxDegreeOfParallelism = 3 };
int count = 0, maxval = 0;
Parallel.ForEach(Enumerable.Range(1, 10000000), po, (d) =>
{
    Interlocked.Increment(ref count);
    dict.AddOrUpdate(Thread.CurrentThread.ManagedThreadId, "", (id, old) => old);

    lock (dict)
    {
        maxval = Math.Max(maxval, count);
    }
    Interlocked.Decrement(ref count);
});

Console.WriteLine("Count: " + count);
Console.WriteLine("Max: " + maxval);
Console.WriteLine("Thread ids: " + String.Join(", ", dict.Select(d => d.Key)));

它应该会产生类似这样的输出：

计数：0
最大：3
线程 ID：1、4、5、6、7、8、9

无论您运行多少次此代码，最大值都不应超过 3。另一方面，线程 ID 会经常更改。