9 instantiations of ListChunk
System.Linq.Parallel (9)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)
241privateBuffers[destinationIndex] = buffer = new ListChunk<Pair<TInputOutput, THashKey>>(INITIAL_PRIVATE_BUFFER_SIZE);
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)
250privateBuffers[destinationIndex] = buffer = new ListChunk<Pair<TInputOutput, THashKey>>(INITIAL_PRIVATE_BUFFER_SIZE); 251privateKeyBuffers[destinationIndex] = keyBuffer = new ListChunk<TOrderKey>(INITIAL_PRIVATE_BUFFER_SIZE);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
263currentValue = new ListChunk<TElement>(INITIAL_CHUNK_SIZE);
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (1)
376_tail = new ListChunk<Pair<TElement, TOrderKey>>(INITIAL_CHUNK_SIZE);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)
342currentValue = new ListChunk<TSource>(INITIAL_CHUNK_SIZE); 404currentValue = new ListChunk<TElement>(INITIAL_CHUNK_SIZE); 742_values = new ListChunk<Pair<TOrderKey, TElement>>(INITIAL_CHUNK_SIZE);
System\Linq\Parallel\Utils\ListChunk.cs (1)
46_tailChunk = new ListChunk<TInputOutput>(tail._chunkCount * 2);
56 references to ListChunk
System.Linq.Parallel (56)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (6)
33private readonly ListChunk<Pair<TInputOutput, THashKey>>[][] _valueExchangeMatrix; // Matrix to do inter-task communication. 42internal ListChunk<Pair<TInputOutput, THashKey>>? _currentBuffer; // The buffer we're currently enumerating. 67CountdownEvent barrier, ListChunk<Pair<TInputOutput, THashKey>>[][] valueExchangeMatrix, CancellationToken cancellationToken) 204ListChunk<Pair<TInputOutput, THashKey>>[] privateBuffers = new ListChunk<Pair<TInputOutput, THashKey>>[_partitionCount]; 237ListChunk<Pair<TInputOutput, THashKey>> buffer = privateBuffers[destinationIndex];
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (12)
33private readonly ListChunk<Pair<TInputOutput, THashKey>>[][] _valueExchangeMatrix; // Matrix to do inter-task communication of values. 34private readonly ListChunk<TOrderKey>[][] _keyExchangeMatrix; // Matrix to do inter-task communication of order keys. 43internal ListChunk<Pair<TInputOutput, THashKey>>? _currentBuffer; // The buffer we're currently enumerating. 44internal ListChunk<TOrderKey>? _currentKeyBuffer; // The buffer we're currently enumerating. 69ListChunk<Pair<TInputOutput, THashKey>>[][] valueExchangeMatrix, ListChunk<TOrderKey>[][] keyExchangeMatrix, CancellationToken cancellationToken) 210ListChunk<Pair<TInputOutput, THashKey>>[] privateBuffers = new ListChunk<Pair<TInputOutput, THashKey>>[_partitionCount]; 211ListChunk<TOrderKey>[] privateKeyBuffers = new ListChunk<TOrderKey>[_partitionCount]; 244ListChunk<Pair<TInputOutput, THashKey>> buffer = privateBuffers[destinationIndex]; 245ListChunk<TOrderKey> keyBuffer = privateKeyBuffers[destinationIndex];
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (4)
28ListChunk<Pair<TInputOutput, THashKey>>[][] valueExchangeMatrix = 29JaggedArray<ListChunk<Pair<TInputOutput, THashKey>>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount); 30ListChunk<TOrderKey>[][] keyExchangeMatrix = 31JaggedArray<ListChunk<TOrderKey>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount);
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (2)
33ListChunk<Pair<TInputOutput, THashKey>>[][] valueExchangeMatrix = 34JaggedArray<ListChunk<Pair<TInputOutput, THashKey>>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (9)
232HashLookup<THashKey, ListChunk<TElement>> lookup = new HashLookup<THashKey, ListChunk<TElement>>(_keyComparer); 246private readonly HashLookup<THashKey, ListChunk<TElement>> _base; 248public GroupJoinBaseHashBuilder(HashLookup<THashKey, ListChunk<TElement>> baseLookup) 259ListChunk<TElement>? currentValue = default(ListChunk<TElement>); 279private sealed class GroupJoinHashLookup : GroupJoinHashLookup<THashKey, TElement, ListChunk<TElement>, int> 283internal GroupJoinHashLookup(HashLookup<THashKey, ListChunk<TElement>> lookup) 290protected override Pair<IEnumerable<TElement>, int> CreateValuePair(ListChunk<TElement> baseValue)
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (4)
53internal ListChunk<Pair<TRightInput, TRightKey>>? _currentRightMatches; // Current right matches (if any). 108ListChunk<Pair<TRightInput, TRightKey>>? currentRightChunk = mutables._currentRightMatches; 341internal ListChunk<Pair<TElement, TOrderKey>>? Tail 348private ListChunk<Pair<TElement, TOrderKey>>? _tail;
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (14)
231internal HashLookup<Wrapper<TGroupKey>, ListChunk<TElement>>? _hashLookup; // The lookup with key-value mappings. 289protected abstract HashLookup<Wrapper<TGroupKey>, ListChunk<TElement>> BuildHashLookup(); 320protected override HashLookup<Wrapper<TGroupKey>, ListChunk<TSource>> BuildHashLookup() 322HashLookup<Wrapper<TGroupKey>, ListChunk<TSource>> hashlookup = 323new HashLookup<Wrapper<TGroupKey>, ListChunk<TSource>>(new WrapperEqualityComparer<TGroupKey>(_keyComparer)); 338ListChunk<TSource>? currentValue = null; 382protected override HashLookup<Wrapper<TGroupKey>, ListChunk<TElement>> BuildHashLookup() 384HashLookup<Wrapper<TGroupKey>, ListChunk<TElement>> hashlookup = 385new HashLookup<Wrapper<TGroupKey>, ListChunk<TElement>>(new WrapperEqualityComparer<TGroupKey>(_keyComparer)); 400ListChunk<TElement>? currentValue = null; 681private readonly KeyValuePair<Wrapper<TGroupKey>, ListChunk<TElement>> _keyValues; // A key value pair. 687internal GroupByGrouping(KeyValuePair<Wrapper<TGroupKey>, ListChunk<TElement>> keyValues) 730private ListChunk<Pair<TOrderKey, TElement>>? _values; // Values in this group 787ListChunk<Pair<TOrderKey, TElement>>? curChunk = _values;
System\Linq\Parallel\Utils\ListChunk.cs (5)
23private ListChunk<TInputOutput>? _nextChunk; 24private ListChunk<TInputOutput> _tailChunk; 43ListChunk<TInputOutput> tail = _tailChunk; 56internal ListChunk<TInputOutput>? Next 74ListChunk<TInputOutput>? curr = this;