# | Line 714 | Line 714 | public class ForkJoinPool extends Abstra | |
---|---|---|
714 | */ | |
715 | private boolean scan(ForkJoinWorkerThread w, int a) { | |
716 | int g = scanGuard; // mask 0 avoids useless scans if only one active | |
717 | < | int m = parallelism == 1 - a? 0 : g & SMASK; |
717 | > | int m = (parallelism == 1 - a && blockedCount == 0) ? 0 : g & SMASK; |
718 | ForkJoinWorkerThread[] ws = workers; | |
719 | if (ws == null || ws.length <= m) // staleness check | |
720 | return false; |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |