PLINQ отложенное выполнение

Question

Я пытаюсь понять, как параллелизм может работать с использованием PLINQ, учитывая задержку выполнения. Вот простой пример.

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

С помощью LINQ, я бы ожидать, что исполнение достичь «получение» значение и возвращает истину, без выполнения запроса для остальных значений.

Если мы сделаем это параллельно, оценка «облегчения» может начаться до того, как результат «получения» вернется. Но как только запрос знает, что «квитанция» приведет к истинному результату, будут ли текущие потоки немедленными?

В моем случае это важно, потому что «любой» тест может быть очень дорогим, и я хотел бы освободить процессоры для выполнения других задач.

Answer 1

К сожалению, другие потоки не будут «немедленно уступать».

Как только Any() найдет действительный элемент, планировщик PLINQ прекратит планирование новых потоков для проверки новых элементов. Любые существующие разделители также получат запрос на отмену, который запретит этим разделам звонить Any() на другой элемент.

Однако любые потоки, которые в настоящее время исполняющие лямбда-выражение в ваш метод Any() еще будет выполнение, поскольку нет никакого способа, чтобы они знали, что другой поток удалось. Это предотвратит вызов новых потоков в Any(), но не отменяет все те, что есть у «очень дорогого» делегата.

На стороне записки:

PLINQ, в отличие от LINQ к объектам, на самом деле не использовать отложенное выполнение. Когда вы вызываете AsParallel() на IEnumerable<T>, генерируемый ParallelQuery<T> фактически начнет обрабатывать вашу процедуру параллельно. Отсроченное исполнение резко снизило бы эффективность PLINQ, так как было бы невозможно запланировать параллельно, не создавая рабочих разделителей и планируя заранее.

---

Edit:

Подумав об этом - если ваш лямбда-очень дорого, вы можете рассмотреть вопрос об использовании CancellationToken. Я подробно рассказал о how cancellation in PLINQ works. Как правило, вы просто используете токен и звоните ThrowIfCancellationRequested() - однако вы также можете использовать CancellationToken и проверить IsCancellationRequested, что позволило бы вам сделать ваш лямбда «выходным раньше», предоставляя вам способ остановить фоновую обработку раньше ...