1 write to _targets
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1051_targets = targets;
17 references to _targets
System.Threading.Tasks.Dataflow (17)
Blocks\JoinBlock.cs (17)
601foreach (JoinBlockTargetBase target in _sharedResources._targets) 749foreach (JoinBlockTargetBase target in _sharedResources._targets) 920foreach (JoinBlockTargetBase target in _sharedResources._targets) 1086internal object IncomingLock { get { return _targets; } } 1091foreach (JoinBlockTargetBase target in _targets) 1103foreach (JoinBlockTargetBase target in _targets) 1120foreach (JoinBlockTargetBase target in _targets) 1143foreach (JoinBlockTargetBase target in _targets) 1181foreach (JoinBlockTargetBase target in _targets) 1193foreach (JoinBlockTargetBase target in _targets) 1207foreach (JoinBlockTargetBase target in _targets) 1224foreach (JoinBlockTargetBase target in _targets) 1290_targets.Max(static t => t.NumberOfMessagesAvailableOrPostponed)); 1322foreach (JoinBlockTargetBase target in _targets) 1349foreach (JoinBlockTargetBase target in sharedResources._targets) target.CompleteOncePossible(); 1397Debug.Assert(_targets.Length > 0, "A join must have targets."); 1398_targets[0].CompleteCore(exception, dropPendingMessages: true, releaseReservedMessages: true);