1058 |
|
long h = eventWaiters; |
1059 |
|
if (h != 0L && (int)(h >>> EVENT_COUNT_SHIFT) != eventCount) |
1060 |
|
releaseEventWaiters(); |
1061 |
– |
if (joinMe.status < 0) |
1062 |
– |
break; |
1061 |
|
if ((workerCounts & RUNNING_COUNT_MASK) != 0) { |
1062 |
|
long ms; int ns; |
1063 |
|
if (!timed) { |
1076 |
|
else |
1077 |
|
ns = (int) (nt % 1000000); |
1078 |
|
} |
1079 |
< |
if (joinMe.internalAwaitDone(ms, ns) < 0) |
1082 |
< |
break; |
1079 |
> |
joinMe.internalAwaitDone(ms, ns); |
1080 |
|
} |
1081 |
+ |
if (joinMe.status < 0) |
1082 |
+ |
break; |
1083 |
|
} |
1084 |
|
helpMaintainParallelism(); |
1085 |
|
} |