1 write to _sharedResources
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
551_sharedResources = sharedResources;
13 references to _sharedResources
System.Threading.Tasks.Dataflow (13)
Blocks\BatchedJoinBlock.cs (13)
562Common.ContractAssertMonitorStatus(_sharedResources._incomingLock, held: true); 576lock (_sharedResources._incomingLock) 580_sharedResources._decliningPermanently) 595if (--_sharedResources._remainingItemsInBatch == 0) _sharedResources._batchSizeReachedAction(); 604lock (_sharedResources._incomingLock) 611if (--_sharedResources._remainingAliveTargets == 0) _sharedResources._allTargetsDecliningPermanentlyAction(); 624lock (_sharedResources._incomingLock) 626if (!_decliningPermanently && !_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception); 629_sharedResources._completionAction(); 664_batchedJoinBlockTarget._sharedResources._decliningPermanently;