c# - PLINQ:如何在超过 4 个线程上运行 ParallelQuery？

Question

更新 - 更改了问题的标题以反射(reflect)我真正想要的

考虑以下代码:

// this query generates 12 instances of Func<int>, which each when executed
// print something to the console and wait for 1 second.
var actions = Enumerable.Range(0, 12).Select(i => new Func<int>(() =>
{
    Console.WriteLine("{0} - waiting 1 sec", i);
    Thread.Sleep(1000);
    return 1;
}));

// define a parallel query. Note the WithDegreeOfParallelism call here.
var query = from action in actions.AsParallel().WithDegreeOfParallelism(12)
            select action();

// execute, measuring total duration
var stopw = Stopwatch.StartNew();
query.ToList();
Console.WriteLine(stopw.Elapsed);
Console.WriteLine(Environment.ProcessorCount); // 3 on my machine

当省略对 WithDegreeOfParallelism 的调用时，这将分 4 个 block 执行，总共花费大约 4 秒，这是我预期的结果，因为我的 CPU 数量是 3。

但是，当使用任何大于 4 的数字调用 WithDegreeOfParallelism 时，我总是得到 3 个 block ，并且总持续时间不低于 3 秒。我希望值 12 的总持续时间(略多于)1 秒。

我错过了什么？我如何才能强制并行执行 4 个以上的非 CPU 密集型任务，这正是我所追求的？

更新:我当然可以回到手动启动线程，但我希望新的 PFX 库能让这更容易一些......无论如何，下面的代码给了我大约 1 秒的总执行时间

List<Thread> threads = new List<Thread>();
for (int i = 0; i < 12; i++)
{
    int i1 = i;
    threads.Add(new Thread(() =>
    {
        Console.WriteLine(i1);
        Thread.Sleep(1000);
    }));
}
threads.ForEach(t => t.Start());
threads.ForEach(t => t.Join());

Answer 1

尝试使用选项 TaskCreationOptions.LongRunning 在并行循环中启动新任务。它们将立即开始，而不是等到线程池中的线程可用。