287 |
|
while ((s = state) == INTERRUPTING) |
288 |
|
Thread.yield(); // wait out pending interrupt |
289 |
|
} |
290 |
< |
assert state == INTERRUPTED; |
290 |
> |
// assert state == INTERRUPTED; |
291 |
|
// Clear any interrupt we may have received. |
292 |
|
Thread.interrupted(); // clear interrupt from cancel(true) |
293 |
|
} |
308 |
|
* nulls out callable. |
309 |
|
*/ |
310 |
|
private void finishCompletion() { |
311 |
< |
assert state > NEW; |
311 |
> |
// assert state > NEW; |
312 |
|
for (WaitNode q; (q = waiters) != null;) { |
313 |
|
if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null)) { |
314 |
|
for (;;) { |