Terraria v1.4.4.9
Terraria source code documentation
|
Classes | |
class | OrderedPipeliningMergeEnumerator |
class | ProducerComparer |
Public Member Functions | |
TOutput[] | GetResultsAsArray () |
Package Functions | |
OrderPreservingPipeliningMergeHelper (PartitionedStream< TOutput, TKey > partitions, TaskScheduler taskScheduler, CancellationState cancellationState, bool autoBuffered, int queryId, IComparer< TKey > keyComparer) | |
Private Member Functions | |
void IMergeHelper< TOutput >. | Execute () |
IEnumerator< TOutput > IMergeHelper< TOutput >. | GetEnumerator () |
Private Attributes | |
readonly QueryTaskGroupState | _taskGroupState |
readonly PartitionedStream< TOutput, TKey > | _partitions |
readonly TaskScheduler | _taskScheduler |
readonly bool | _autoBuffered |
readonly Queue< Pair< TKey, TOutput > >[] | _buffers |
readonly bool[] | _producerDone |
readonly bool[] | _producerWaiting |
readonly bool[] | _consumerWaiting |
readonly object[] | _bufferLocks |
readonly IComparer< Producer< TKey > > | _producerComparer |
Definition at line 8 of file OrderPreservingPipeliningMergeHelper.cs.