1 write to _targets
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
1036
_targets
= targets;
17 references to _targets
System.Threading.Tasks.Dataflow (17)
Blocks\JoinBlock.cs (17)
589
foreach (JoinBlockTargetBase target in _sharedResources.
_targets
)
737
foreach (JoinBlockTargetBase target in _sharedResources.
_targets
)
908
foreach (JoinBlockTargetBase target in _sharedResources.
_targets
)
1071
internal object IncomingLock { get { return
_targets
; } }
1076
foreach (JoinBlockTargetBase target in
_targets
)
1088
foreach (JoinBlockTargetBase target in
_targets
)
1105
foreach (JoinBlockTargetBase target in
_targets
)
1128
foreach (JoinBlockTargetBase target in
_targets
)
1166
foreach (JoinBlockTargetBase target in
_targets
)
1178
foreach (JoinBlockTargetBase target in
_targets
)
1192
foreach (JoinBlockTargetBase target in
_targets
)
1209
foreach (JoinBlockTargetBase target in
_targets
)
1275
_targets
.Max(static t => t.NumberOfMessagesAvailableOrPostponed));
1307
foreach (JoinBlockTargetBase target in
_targets
)
1334
foreach (JoinBlockTargetBase target in sharedResources.
_targets
) target.CompleteOncePossible();
1382
Debug.Assert(
_targets
.Length > 0, "A join must have targets.");
1383
_targets
[0].CompleteCore(exception, dropPendingMessages: true, releaseReservedMessages: true);