# | Line 951 | Line 951 | public class ForkJoinWorkerThread extend | |
---|---|---|
951 | ||
952 | /** | |
953 | * Run tasks in local queue until given task is done. | |
954 | + | * Not currently used because it complicates semantics. |
955 | * | |
956 | * @param joinMe the task to join | |
957 | */ | |
# | Line 1016 | Line 1017 | public class ForkJoinWorkerThread extend | |
1017 | if (j < n) { | |
1018 | ForkJoinTask<?> vs; | |
1019 | if ((v = ws[j]) != null && | |
1020 | + | (v != this || base == sp) && |
1021 | (vs = v.currentSteal) != null) { | |
1022 | if (joinMe.status < 0 || task.status < 0) | |
1023 | return; // stale or done |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |