infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-06-11 13:05:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Undo a redundant signal screen

Browse Source
This commit is contained in:
Doug Lea 2026-06-11 07:32:59 -04:00
parent 68112d6c94
commit 0b0d84c3a5
1 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/java.base/share/classes/java/util/concurrent/ForkJoinPool.java
View File

@ -1989,7 +1989,7 @@ public class ForkJoinPool extends AbstractExecutorService
int qid, cap; WorkQueue q; ForkJoinTask<?>[] a;
if ((q = qs[qid = i & (n - 1)]) != null &&
(a = q.array) != null && (cap = a.length) > 0) {
int m = cap - 1, b = q.base, prevb = b - 1, propagated = prevb;
int m = cap - 1, b = q.base, prevb = b - 1;
for (; ; prevb = b) { // track stalls
int nb; long bp;
ForkJoinTask<?> t = (ForkJoinTask<?>)
@ -2010,12 +2010,10 @@ public class ForkJoinPool extends AbstractExecutorService
break scan;
break; // probably empty
}
if (b == prevb) { // stalled
rescan = true;
break scan; // reorder scan
if (b == prevb || src != qid) {
rescan = true; // stalled or busy
break scan; // reorder scan
}
if (b == propagated)
propagated = nb;
}
}
else {
@ -2026,12 +2024,9 @@ public class ForkJoinPool extends AbstractExecutorService
w.source = src = qid; // volatile
if (more &&
(prevSrc != qid ||
((qid & 1) == 0 && b != propagated &&
(fifo != 0 || t.noUserHelp() != 0))) &&
U.getReferenceAcquire(a, np) != null) {
propagated = nb;
((qid & 1) == 0 &&
(fifo != 0 || t.noUserHelp() != 0))))
signalWork();
}
w.topLevelExec(t, fifo);
rescan = true;
b = q.base;