5 writes to _numberOfOutstandingOperations
System.Threading.Tasks.Dataflow (5)
Internal\TargetCore.cs (5)
170_numberOfOutstandingOperations--; 260if (_numberOfOutstandingOperations > 0) _numberOfOutstandingOperations--; 369_numberOfOutstandingOperations++; 496_numberOfOutstandingOperations--; 533if (parallelismAvailable) ++_numberOfOutstandingOperations;
12 references to _numberOfOutstandingOperations
System.Threading.Tasks.Dataflow (12)
Internal\TargetCore.cs (12)
153Debug.Assert(_numberOfOutstandingOperations > 0 || !storeExceptionEvenIfAlreadyCompleting, 168Debug.Assert(_numberOfOutstandingOperations > 0 && (!UsesAsyncCompletion || _numberOfOutstandingServiceTasks > 0), 259Debug.Assert(_numberOfOutstandingOperations > 0, "Operations may only be completed if any are outstanding."); 260if (_numberOfOutstandingOperations > 0) _numberOfOutstandingOperations--; 295Debug.Assert(_numberOfOutstandingOperations >= 0, "Number of outstanding operations should never be negative."); 297Debug.Assert(_numberOfOutstandingOperations >= _numberOfOutstandingServiceTasks, "Number of outstanding service tasks should never exceed the number of outstanding operations."); 302return (_numberOfOutstandingOperations - _numberOfOutstandingServiceTasks) < _dataflowBlockOptions.ActualMaxDegreeOfParallelism; 311Debug.Assert(_numberOfOutstandingOperations >= 0, "Number of outstanding operations should never be negative."); 313Debug.Assert(_numberOfOutstandingOperations >= _numberOfOutstandingServiceTasks, "Number of outstanding service tasks should never exceed the number of outstanding operations."); 495Debug.Assert(_numberOfOutstandingOperations > 0, "Expected a positive number of outstanding operations, since we're completing one here."); 733bool notCurrentlyProcessing = _numberOfOutstandingOperations == 0; 865internal int CurrentDegreeOfParallelism { get { return _target._numberOfOutstandingOperations - _target._numberOfOutstandingServiceTasks; } }