1 write to _sharedResources
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
330_sharedResources = new BatchedJoinBlockTargetSharedResources(
9 references to _sharedResources
System.Threading.Tasks.Dataflow (9)
Blocks\BatchedJoinBlock.cs (9)
340_target1 = new BatchedJoinBlockTarget<T1>(_sharedResources); 341_target2 = new BatchedJoinBlockTarget<T2>(_sharedResources); 342_target3 = new BatchedJoinBlockTarget<T3>(_sharedResources); 415Debug.Assert(_sharedResources != null, "_sharedResources not initialized"); 416Debug.Assert(_sharedResources._incomingLock != null, "_sharedResources._incomingLock not initialized"); 419lock (_sharedResources._incomingLock) 421if (!_sharedResources._decliningPermanently) _source.AddException(exception); 490public long BatchesCreated { get { return _batchedJoinBlock._sharedResources._batchesCreated; } } 492public int RemainingItemsForBatch { get { return _batchedJoinBlock._sharedResources._remainingItemsInBatch; } }