1 write to _sharedResources
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
82_sharedResources = new BatchedJoinBlockTargetSharedResources(
8 references to _sharedResources
System.Threading.Tasks.Dataflow (8)
Blocks\BatchedJoinBlock.cs (8)
92_target1 = new BatchedJoinBlockTarget<T1>(_sharedResources); 93_target2 = new BatchedJoinBlockTarget<T2>(_sharedResources); 161Debug.Assert(_sharedResources != null, "_sharedResources not initialized"); 162Debug.Assert(_sharedResources._incomingLock != null, "_sharedResources._incomingLock not initialized"); 165lock (_sharedResources._incomingLock) 167if (!_sharedResources._decliningPermanently) _source.AddException(exception); 235public long BatchesCreated { get { return _batchedJoinBlock._sharedResources._batchesCreated; } } 237public int RemainingItemsForBatch { get { return _batchedJoinBlock._sharedResources._remainingItemsInBatch; } }