464 |
|
try { |
465 |
|
task.cancel(true); |
466 |
|
shouldThrow(); |
467 |
< |
} catch (SecurityException expected) {} |
467 |
> |
} catch (SecurityException success) {} |
468 |
|
|
469 |
|
// We failed to deliver the interrupt, but the world retains |
470 |
|
// its sanity, as if we had done task.cancel(false) |
756 |
|
public void realRun() throws Exception { |
757 |
|
Thread.currentThread().interrupt(); |
758 |
|
try { |
759 |
< |
task.get(2*LONG_DELAY_MS, MILLISECONDS); |
759 |
> |
task.get(randomTimeout(), randomTimeUnit()); |
760 |
|
shouldThrow(); |
761 |
|
} catch (InterruptedException success) {} |
762 |
|
assertFalse(Thread.interrupted()); |
763 |
|
|
764 |
|
pleaseInterrupt.countDown(); |
765 |
|
try { |
766 |
< |
task.get(2*LONG_DELAY_MS, MILLISECONDS); |
766 |
> |
task.get(LONGER_DELAY_MS, MILLISECONDS); |
767 |
|
shouldThrow(); |
768 |
|
} catch (InterruptedException success) {} |
769 |
|
assertFalse(Thread.interrupted()); |
770 |
|
}}); |
771 |
|
|
772 |
|
await(pleaseInterrupt); |
773 |
+ |
if (randomBoolean()) assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
774 |
|
t.interrupt(); |
775 |
|
awaitTermination(t); |
776 |
|
checkNotDone(task); |