1 instantiation of SynchronousChannel
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
195channels[i] = new SynchronousChannel<TInputOutput>();
12 references to SynchronousChannel
System.Linq.Parallel (12)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
31private readonly SynchronousChannel<TInputOutput>[]? _syncChannels; // Destination channels (sync).
System\Linq\Parallel\Merging\MergeExecutor.cs (3)
186internal static SynchronousChannel<TInputOutput>[] MakeSynchronousChannels(int partitionCount) 188SynchronousChannel<TInputOutput>[] channels = new SynchronousChannel<TInputOutput>[partitionCount];
System\Linq\Parallel\Merging\SynchronousChannelMergeEnumerator.cs (4)
25private readonly SynchronousChannel<T>[] _channels; // The channel array we will enumerate, from left-to-right. 34QueryTaskGroupState taskGroupState, SynchronousChannel<T>[] channels) : base(taskGroupState) 38foreach (SynchronousChannel<T> c in channels) Debug.Assert(c != null); 89SynchronousChannel<T> current = _channels[_channelIndex];
System\Linq\Parallel\Scheduling\SpoolingTask.cs (4)
34SynchronousChannel<TInputOutput>[] channels, TaskScheduler taskScheduler) 188private readonly SynchronousChannel<TInputOutput> _destination; 204QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, SynchronousChannel<TInputOutput> destination) 225SynchronousChannel<TInputOutput> destination = _destination;