1 instantiation of IntValueEvent
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
54
IntValueEvent consumerEvent = new
IntValueEvent
();
7 references to IntValueEvent
System.Linq.Parallel (7)
System\Linq\Parallel\Channels\AsynchronousChannel.cs (3)
87
private
IntValueEvent
? _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)
35
private
IntValueEvent
? _consumerEvent; // The consumer event.
45
QueryTaskGroupState taskGroupState, AsynchronousChannel<T>[] channels,
IntValueEvent
? consumerEvent)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
54
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)