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); 164Debug.Assert(_sharedResources != null, "_sharedResources not initialized"); 165Debug.Assert(_sharedResources._incomingLock != null, "_sharedResources._incomingLock not initialized"); 168lock (_sharedResources._incomingLock) 170if (!_sharedResources._decliningPermanently) _source.AddException(exception); 238public long BatchesCreated { get { return _batchedJoinBlock._sharedResources._batchesCreated; } } 240public int RemainingItemsForBatch { get { return _batchedJoinBlock._sharedResources._remainingItemsInBatch; } }