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