1 instantiation of IntValueEvent
System.Core (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
58
IntValueEvent consumerEvent = new
IntValueEvent
();
7 references to IntValueEvent
System.Core (7)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (3)
87
private
IntValueEvent
m_consumerEvent;
109
internal AsynchronousChannel(int index, int chunkSize, CancellationToken cancellationToken,
IntValueEvent
consumerEvent) :
114
internal AsynchronousChannel(int index, int capacity, int chunkSize, CancellationToken cancellationToken,
IntValueEvent
consumerEvent)
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (2)
38
private
IntValueEvent
m_consumerEvent; // The consumer event.
48
QueryTaskGroupState taskGroupState, AsynchronousChannel<T>[] channels,
IntValueEvent
consumerEvent)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
58
IntValueEvent
consumerEvent = new IntValueEvent();
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
147
internal static AsynchronousChannel<TInputOutput>[] MakeAsynchronousChannels(int partitionCount, ParallelMergeOptions options,
IntValueEvent
consumerEvent, CancellationToken cancellationToken)