PLINQ延迟执行

Question

我正在尝试理解在给定延迟执行的情况下，并行如何使用PLINQ工作。这里有一个简单的例子。

string[] words = { "believe", "receipt", "relief", "field" };
bool result = words.AsParallel().Any(w => w.Contains("ei"));

使用LINQ，我期望执行达到"receipt“值并返回true，而不执行对其余值的查询。

如果我们同时执行此操作，则在“接收”的结果返回之前，可能已经开始对“缓解”进行评估。但是，一旦查询知道"receipt“将导致true结果，其他线程是否会立即产生结果？

在我的例子中，这一点很重要，因为"any“测试可能非常昂贵，而且我希望释放处理器来执行其他任务。

Answer 1

不幸的是，其他线程不会立即“让步”。

一旦Any()找到一个有效的元素，PLINQ调度器就会停止调度新的线程来检查新的元素。任何现有的分区程序也将收到一个取消请求，这将阻止这些分区在另一个项目上调用Any()。

但是，当前正在中执行Any()方法中的lambda表达式的任何线程仍将执行，因为它们没有办法知道另一个线程已经成功。它将阻止新线程调用Any()，但不会取消“非常昂贵”的委托中的所有线程。

顺便说一句：

与LINQ to Objects不同，PLINQ实际上并不使用延迟执行。当您在IEnumerable<T>上调用AsParallel()时，生成的ParallelQuery<T>实际上将开始并行处理您的例程。延迟执行将极大地降低PLINQ的有效性，因为如果不提前创建工作分割器和调度，就不可能并行调度。

编辑：

考虑到这一点--如果您的lambda非常昂贵，您可能想要考虑使用CancellationToken。我详细地写了关于how cancellation in PLINQ works的博客。通常，您只需使用一个令牌并调用ThrowIfCancellationRequested() --然而，您也可以使用一个CancellationToken并检查IsCancellationRequested，这将使您的lambda“提前退出”，并为您提供一种更快停止后台处理的方法……