1 write to _sharedResources
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
545_sharedResources = sharedResources;
13 references to _sharedResources
System.Threading.Tasks.Dataflow (13)
Blocks\BatchedJoinBlock.cs (13)
556Common.ContractAssertMonitorStatus(_sharedResources._incomingLock, held: true); 570lock (_sharedResources._incomingLock) 574_sharedResources._decliningPermanently) 589if (--_sharedResources._remainingItemsInBatch == 0) _sharedResources._batchSizeReachedAction(); 598lock (_sharedResources._incomingLock) 605if (--_sharedResources._remainingAliveTargets == 0) _sharedResources._allTargetsDecliningPermanentlyAction(); 615lock (_sharedResources._incomingLock) 617if (!_decliningPermanently && !_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception); 620_sharedResources._completionAction(); 655_batchedJoinBlockTarget._sharedResources._decliningPermanently;