30 writes to Value
System.Linq.Parallel (30)
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
105
_currentCount.
Value
= nextCount;
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (1)
108
++_currentIndex.
Value
;
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
369
int current = ++_currentIndex.
Value
;
540
int current = ++_currentIndex.
Value
;
661
_exceptionTracker.
Value
= true;
678
_currentIndex.
Value
+= i;
703
if (Interlocked.Decrement(ref _activeEnumeratorsCount.
Value
) == 0)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)
202
if ((_outputLoopCount.
Value
++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)
189
if ((_outputLoopCount.
Value
++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (1)
264
if ((_outputLoopCount.
Value
++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (1)
72
_topLevelDisposedFlag.
Value
= true;
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
219
_resultFoundFlag.
Value
= true;
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
196
_resultFoundFlag.
Value
= true;
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
190
Interlocked.Increment(ref _sharedEmptyCount.
Value
);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
157
if ((_outputLoopCount.
Value
++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
215
_resultFoundFlag.
Value
= true;
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
174
if ((_outputLoopCount.
Value
++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
144
_bufferIndex.
Value
++;
150
if (--_bufferIndex.
Value
>= 0)
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (2)
157
Interlocked.Increment(ref _totalElementCount.
Value
);
176
if (Volatile.Read(ref _totalElementCount.
Value
) > 1)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (3)
252
++_bufferIndex.
Value
;
281
for (_bufferIndex.
Value
++; _bufferIndex.Value < _buffer.Count; _bufferIndex.
Value
++)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (3)
355
++_bufferIndex.
Value
;
374
for (_bufferIndex.
Value
++; _bufferIndex.Value < _buffer.Count; _bufferIndex.
Value
++)
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
139
if ((_outputLoopCount.
Value
++ & CancellationState.POLL_INTERVAL) == 0)
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
144
_results.
Value
= sortedOutput;
System\Linq\Parallel\Utils\Shared.cs (1)
22
this.
Value
= value;
38 references to Value
System.Linq.Parallel (38)
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
102
int nextCount = _currentCount.
Value
+ 1;
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (2)
106
if (_currentIndex.
Value
< (_count - 1))
110
currentKey = _currentIndex.
Value
+ _indexOffset;
System\Linq\Parallel\Merging\MergeEnumerator.cs (1)
68
Debug.Assert(_taskGroupState.CancellationState.TopLevelDisposedFlag.
Value
);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (3)
69
Debug.Assert(_results.
Value
!= null);
70
return ((IEnumerable<TInputOutput>)_results.
Value
).GetEnumerator();
80
return _results.
Value
;
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (2)
646
if (_exceptionTracker.
Value
)
675
mutables._chunkBaseIndex = _currentIndex.
Value
;
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (1)
90
if (_topLevelDisposedFlag.
Value
)
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (2)
189
if (_resultFoundFlag.
Value
)
209
if (_resultFoundFlag.
Value
)
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (2)
167
if (_resultFoundFlag.
Value
)
186
if (_resultFoundFlag.
Value
)
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
174
if (_sharedEmptyCount.
Value
== _partitionCount - 1)
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
206
if (_resultFoundFlag.
Value
)
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
152
currentElement = _buffer[_bufferIndex.
Value
].First;
153
currentKey = _buffer[_bufferIndex.
Value
].Second;
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (9)
246
if (_count == 0 || _bufferIndex.
Value
>= _buffer.Count - 1)
253
currentElement = _buffer[_bufferIndex.
Value
].First;
254
currentKey = _buffer[_bufferIndex.
Value
].Second;
258
|| _keyComparer.Compare(_buffer[_bufferIndex.
Value
].Second, _sharedIndices.MaxValue) <= 0;
279
if (_bufferIndex.
Value
< _buffer.Count - 1)
281
for (_bufferIndex.Value++; _bufferIndex.
Value
< _buffer.Count; _bufferIndex.Value++)
285
if (_keyComparer.Compare(_buffer[_bufferIndex.
Value
].Second, minKey) > 0)
287
currentElement = _buffer[_bufferIndex.
Value
].First;
288
currentKey = _buffer[_bufferIndex.
Value
].Second;
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (8)
349
if (_bufferIndex.
Value
>= _buffer.Count - 1)
356
currentElement = _buffer[_bufferIndex.
Value
].First;
357
currentKey = _buffer[_bufferIndex.
Value
].Second;
372
if (_bufferIndex.
Value
< _buffer.Count - 1)
374
for (_bufferIndex.Value++; _bufferIndex.
Value
< _buffer.Count; _bufferIndex.Value++)
378
if (_keyComparer.Compare(_buffer[_bufferIndex.
Value
].Second, _operatorState._currentLowKey) >= 0)
380
currentElement = _buffer[_bufferIndex.
Value
].First;
381
currentKey = _buffer[_bufferIndex.
Value
].Second;
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
77
Debug.Assert(results.
Value
== null);
System\Linq\Parallel\Scheduling\QueryTaskGroupState.cs (2)
151
if (!_cancellationState.TopLevelDisposedFlag.
Value
)
158
Debug.Assert(_cancellationState.TopLevelDisposedFlag.
Value
);