1 instantiation of SynchronousChannel
System.Core (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
195channels[i] = new SynchronousChannel<TInputOutput>();
11 references to SynchronousChannel
System.Core (11)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
35private SynchronousChannel<TInputOutput>[] m_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 (3)
31private SynchronousChannel<T>[] m_channels; // The channel array we will enumerate, from left-to-right. 40QueryTaskGroupState taskGroupState, SynchronousChannel<T>[] channels) : base(taskGroupState) 95SynchronousChannel<T> current = m_channels[m_channelIndex];
System\Linq\Parallel\Scheduling\SpoolingTask.cs (4)
39SynchronousChannel<TInputOutput>[] channels, TaskScheduler taskScheduler) 191private SynchronousChannel<TInputOutput> m_destination; 207QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, SynchronousChannel<TInputOutput> destination) 228SynchronousChannel<TInputOutput> destination = m_destination;