27 references to Shared
System.Linq.Parallel (27)
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
99_currentCount ??= new Shared<int>(-1);
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (1)
104_currentIndex ??= new Shared<int>(-1);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
47_results = new Shared<TInputOutput[]?>(null);
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
170Shared<int> sharedCurrentIndex = new Shared<int>(0); 171Shared<int> sharedPartitionCount = new Shared<int>(partitionCount); 172Shared<bool> sharedExceptionTracker = new Shared<bool>(false); 366_currentIndex ??= new Shared<int>(_startIndex); 537_currentIndex ??= new Shared<int>(_startIndex);
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)
178_outputLoopCount = new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)
166_outputLoopCount = new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (1)
220_outputLoopCount = new Shared<int>(0);
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (1)
41private readonly Shared<bool> _topLevelDisposedFlag = new Shared<bool>(false); //a shared<bool> so that it can be referenced by others.
System\Linq\Parallel\QueryOperators\QuerySettings.cs (1)
137return WithPerExecutionSettings(new CancellationTokenSource(), new Shared<bool>(false));
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
106Shared<bool> resultFoundFlag = new Shared<bool>(false);
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
90Shared<bool> resultFoundFlag = new Shared<bool>(false);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
65Shared<int> sharedEmptyCount = new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
153_outputLoopCount ??= new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
83Shared<bool> resultFoundFlag = new Shared<bool>(false);
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
51Shared<bool> dummyTopLevelDisposeFlag = new Shared<bool>(false);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
170_outputLoopCount ??= new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)
132_bufferIndex = new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
62Shared<int> totalElementCount = new Shared<int>(0);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
236_bufferIndex = new Shared<int>(-1);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
339_bufferIndex = new Shared<int>(-1);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
135_outputLoopCount ??= new Shared<int>(0);
System\Linq\Parallel\Scheduling\CancellationState.cs (1)
49TopLevelDisposedFlag = new Shared<bool>(false); //it would always be initialized to false, so no harm doing it here and avoid #if around constructors.
System\Linq\ParallelEnumerable.cs (1)
4386.WithPerExecutionSettings(new CancellationTokenSource(), new System.Linq.Parallel.Shared<bool>(false));