OrderPreservingPipeliningMergeHelper`2

: Object

System.Linq.Parallel.OrderPreservingPipeliningMergeHelper`2, System.Core 0x0060 (96 B) align 8 inherited 0x0010 System.Core

implements IMergeHelper`1

0x00x0060

Members 13

Show inherited members

Offset	Size	Name	Type	Flags
—	0x08	_taskGroupState	QueryTaskGroupState	Private+1 flags
—	0x08	_partitions	PartitionedStream`2	Private+1 flags
—	0x08	_taskScheduler	TaskScheduler	Private+1 flags
—	0x01	_autoBuffered	bool	Private+1 flags
—	0x08	_buffers	Queue`1[]	Private+1 flags
—	0x08	_producerDone	bool[]	Private+1 flags
—	0x08	_producerWaiting	bool[]	Private+1 flags
—	0x08	_consumerWaiting	bool[]	Private+1 flags
—	0x08	_bufferLocks	object[]	Private+1 flags
—	0x08	_producerComparer	IComparer`1	Private
—	0x04	INITIAL_BUFFER_SIZE	int	Static+2 flags
—	0x04	STEAL_BUFFER_SIZE	int	Static+2 flags
—	0x04	MAX_BUFFER_SIZE	int	Static+2 flags
0x0010	0x50	unreflected bytes to end of OrderPreservingPipeliningMergeHelper`2

Functions 4

Signature	Flags	Native	Params
void .ctor()	2 flags	—	0x00
void System.Linq.Parallel.IMergeHelper<TOutput>.Execute()	PrivateFinal+2 flags	—	0x00
void System.Linq.Parallel.IMergeHelper<TOutput>.GetEnumerator()	PrivateFinal+2 flags	—	0x00
void GetResultsAsArray()	PublicFinal+2 flags	—	0x00

Used by 1

types with a member, parameter or interface of this type

OrderedPipeliningMergeEnumerator

// System.Linq.Parallel.OrderPreservingPipeliningMergeHelper`2, System.Core
// size 0x0060 (96), inherited 0x0010, align 8
class OrderPreservingPipeliningMergeHelper`2 : public Object
{
public:
    QueryTaskGroupState _taskGroupState;               // ????(0x08) Private InitOnly
    PartitionedStream`2 _partitions;                   // ????(0x08) Private InitOnly
    TaskScheduler _taskScheduler;                      // ????(0x08) Private InitOnly
    bool _autoBuffered;                                // ????(0x01) Private InitOnly
    Queue`1[] _buffers;                                // ????(0x08) Private InitOnly
    bool[] _producerDone;                              // ????(0x08) Private InitOnly
    bool[] _producerWaiting;                           // ????(0x08) Private InitOnly
    bool[] _consumerWaiting;                           // ????(0x08) Private InitOnly
    object[] _bufferLocks;                             // ????(0x08) Private InitOnly
    IComparer`1 _producerComparer;                     // ????(0x08) Private
    int INITIAL_BUFFER_SIZE;                           // ????(0x04) Assembly Static Literal
    int STEAL_BUFFER_SIZE;                             // ????(0x04) Assembly Static Literal
    int MAX_BUFFER_SIZE;                               // ????(0x04) Assembly Static Literal
    uint8 pad_0[0x50];                             // 0x0010(0x50)

    void .ctor(); [Assembly SpecialName]
    void System.Linq.Parallel.IMergeHelper<TOutput>.Execute(); [Private Final Virtual NewSlot]
    void System.Linq.Parallel.IMergeHelper<TOutput>.GetEnumerator(); [Private Final Virtual NewSlot]
    void GetResultsAsArray(); [Public Final Virtual NewSlot]
};