1 write to _sharedResources
System.Threading.Tasks.Dataflow (1)
Blocks\BatchedJoinBlock.cs (1)
333_sharedResources = new BatchedJoinBlockTargetSharedResources(
9 references to _sharedResources
System.Threading.Tasks.Dataflow (9)
Blocks\BatchedJoinBlock.cs (9)
343_target1 = new BatchedJoinBlockTarget<T1>(_sharedResources); 344_target2 = new BatchedJoinBlockTarget<T2>(_sharedResources); 345_target3 = new BatchedJoinBlockTarget<T3>(_sharedResources); 421Debug.Assert(_sharedResources != null, "_sharedResources not initialized"); 422Debug.Assert(_sharedResources._incomingLock != null, "_sharedResources._incomingLock not initialized"); 425lock (_sharedResources._incomingLock) 427if (!_sharedResources._decliningPermanently) _source.AddException(exception); 496public long BatchesCreated { get { return _batchedJoinBlock._sharedResources._batchesCreated; } } 498public int RemainingItemsForBatch { get { return _batchedJoinBlock._sharedResources._remainingItemsInBatch; } }