AsParallel()的最大并行度

您可以使用 ParallelEnumerable.WithDegreeOfParallelism :

设置要在查询中使用的并行度。学位 并行性是同时执行的任务的最大数量 将用于处理查询。

var result = Tabel.AsEnumberable()
                  .AsParallel()
                  .WithDegreeOfParallelism(number)
                  .Where(/* predicate */);

编辑:

@斯维克在 ParallelOptions.MaxDegreeOfParallelism vs PLINQ’s WithDegreeOfParallelism 这强调了两者之间的区别:

并行工作使用我们称为复制任务的隐藏概念。其概念是,一个循环将以一个任务开始处理该循环,但如果有更多线程可用于辅助处理,则将创建其他任务以在这些线程上运行。这使得资源消耗最小化。 考虑到这一点,如果说ParallelOptions支持DegreeOfParallelism的规范是不准确的,因为它实际上是一个最大的度 :循环以1度开始,并且可以在资源可用时达到指定的最大值。

PLINQ不同。PLINQ中一些重要的标准查询运算符需要在处理查询的线程之间进行通信,包括一些依赖于屏障使线程能够在锁定步骤中操作的线程。PLINQ设计要求主动参与特定数量的线程,以便查询取得任何进展。因此,当为PLINQ指定DegreeOfParallelism时 将涉及的线程的实际数量,而不仅仅是最大数量。

是的,你当然可以做到。你只是用 WithDegreeOfParallelism 延伸法

yourSequence.AsParallel()
    .WithDegreeOfParallelism(5)//Whatever number as you like
    .Where(...);

<IEnumerable>.AsParallel()
.WithDegreeOfParallelism(n)
.Where(x=>)