Допустим, имеется ленивая коллекция типа IEnumerable
(не важно каким образом она получена), которая будет параллельно обработана оператором Select
из PLINQ. Для этого будет создан так называемый Chunk Partition
, который будет обработан N-ым количеством worker тредов (тут стоит отметить, что коллекция не индексируема, поэтому будет применен именно Chunk partition
). Каждый такой тред будет обрабатывать chunk
при помощи итератора типа ContiguousChunkLazyEnumerator
. Вот отрывок кода MoveNext
метода ContiguousChunkLazyEnumerator
класса (из .Net source code):
lock (m_sourceSyncLock)
{
// Some .net stuff
try
{
for (; i < mutables.m_nextChunkMaxSize && m_source.MoveNext(); i++)
{
// Read the current entry into our buffer.
chunkBuffer[i] = m_source.Current;
}
}
// Some .net stuff
}
Как видно из кода, каждый такой итератор работает с расшаренным объектом m_source
типа IEnumerator
. Меня интересует следующий вопрос. Как такой подход может давать прирост производительности. Ведь по сути использование блокировки должно полностью убивать производительность (параллелизм по сути не будет давать преимуществ). И по идее, такой же код исполняемый последовательно одним тредом и без блокировки будет иметь такую же производительность.
Такая реализация не совсем понятна для меня, может быть я что-то не учел? (в многопоточности я еще неопытен, буду благодарен за ответы).