System.Linq.Parallel.OrderPreservingPipeliningSpoolingTask< TOutput, TKey > Class Template Reference

Static Public Member Functions
static void	Spool (QueryTaskGroupState groupState, PartitionedStream< TOutput, TKey > partitions, bool[] consumerWaiting, bool[] producerWaiting, bool[] producerDone, Queue< Pair< TKey, TOutput > >[] buffers, object[] bufferLocks, TaskScheduler taskScheduler, bool autoBuffered)

Protected Member Functions
override void	SpoolingWork ()
override void	SpoolingFinally ()
override void	Work ()

Protected Attributes
int	_taskIndex
QueryTaskGroupState	_groupState

Package Functions
	OrderPreservingPipeliningSpoolingTask (QueryOperatorEnumerator< TOutput, TKey > partition, QueryTaskGroupState taskGroupState, bool[] consumerWaiting, bool[] producerWaiting, bool[] producerDone, int partitionIndex, Queue< Pair< TKey, TOutput > >[] buffers, object bufferLock, bool autoBuffered)
Task	RunSynchronously (TaskScheduler taskScheduler)
Task	RunAsynchronously (TaskScheduler taskScheduler)

Private Member Functions
void	BaseWork (object unused)

Static Private Member Functions
static void	RunTaskSynchronously (object o)

Private Attributes
readonly QueryTaskGroupState	_taskGroupState
readonly QueryOperatorEnumerator< TOutput, TKey >	_partition
readonly bool[]	_consumerWaiting
readonly bool[]	_producerWaiting
readonly bool[]	_producerDone
readonly int	_partitionIndex
readonly Queue< Pair< TKey, TOutput > >[]	_buffers
readonly object	_bufferLock
readonly bool	_autoBuffered

Static Private Attributes
static readonly Action< object >	s_runTaskSynchronouslyDelegate = RunTaskSynchronously
static readonly Action< object >	s_baseWorkDelegate

Detailed Description

Definition at line 7 of file OrderPreservingPipeliningSpoolingTask.cs.

---

The documentation for this class was generated from the following file:

• source/System.Linq.Parallel/System.Linq.Parallel/OrderPreservingPipeliningSpoolingTask.cs