1 instantiation of AsynchronousChannel
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
168channels[i] = new AsynchronousChannel<TInputOutput>(i, chunkSize, cancellationToken, consumerEvent);
12 references to AsynchronousChannel
System.Linq.Parallel (12)
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (4)
34private readonly AsynchronousChannel<T>[] _channels; // The channels being enumerated. 45QueryTaskGroupState taskGroupState, AsynchronousChannel<T>[] channels, IntValueEvent? consumerEvent) 50foreach (AsynchronousChannel<T> c in channels) Debug.Assert(c != null); 129AsynchronousChannel<T> current = _channels[currChannelIndex];
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
30private readonly AsynchronousChannel<TInputOutput>[]? _asyncChannels; // Destination channels (async).
System\Linq\Parallel\Merging\MergeExecutor.cs (3)
147internal static AsynchronousChannel<TInputOutput>[] MakeAsynchronousChannels(int partitionCount, ParallelMergeOptions options, IntValueEvent? consumerEvent, CancellationToken cancellationToken) 149AsynchronousChannel<TInputOutput>[] channels = new AsynchronousChannel<TInputOutput>[partitionCount];
System\Linq\Parallel\Scheduling\SpoolingTask.cs (4)
90AsynchronousChannel<TInputOutput>[] channels, TaskScheduler taskScheduler) 277private readonly AsynchronousChannel<TInputOutput> _destination; 293QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, AsynchronousChannel<TInputOutput> destination) 314AsynchronousChannel<TInputOutput> destination = _destination;