1 instantiation of AsynchronousChannel
System.Core (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
168
channels[i] = new
AsynchronousChannel
<TInputOutput>(i, chunkSize, cancellationToken, consumerEvent);
11 references to AsynchronousChannel
System.Core (11)
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (3)
37
private
AsynchronousChannel
<T>[] m_channels; // The channels being enumerated.
48
QueryTaskGroupState taskGroupState,
AsynchronousChannel
<T>[] channels, IntValueEvent consumerEvent)
132
AsynchronousChannel
<T> current = m_channels[currChannelIndex];
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
34
private
AsynchronousChannel
<TInputOutput>[] m_asyncChannels; // Destination channels (async).
System\Linq\Parallel\Merging\MergeExecutor.cs (3)
147
internal static
AsynchronousChannel
<TInputOutput>[] MakeAsynchronousChannels(int partitionCount, ParallelMergeOptions options, IntValueEvent consumerEvent, CancellationToken cancellationToken)
149
AsynchronousChannel
<TInputOutput>[] channels = new
AsynchronousChannel
<TInputOutput>[partitionCount];
System\Linq\Parallel\Scheduling\SpoolingTask.cs (4)
92
AsynchronousChannel
<TInputOutput>[] channels, TaskScheduler taskScheduler)
280
private
AsynchronousChannel
<TInputOutput> m_destination;
296
QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source,
AsynchronousChannel
<TInputOutput> destination)
317
AsynchronousChannel
<TInputOutput> destination = m_destination;