138 |
|
}}); |
139 |
|
|
140 |
|
await(pleaseInterrupt); |
141 |
< |
assertThreadStaysAlive(t); |
141 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
142 |
|
t.interrupt(); |
143 |
|
awaitTermination(t); |
144 |
|
assertEquals(0, q.remainingCapacity()); |
196 |
|
q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); |
197 |
|
shouldThrow(); |
198 |
|
} catch (InterruptedException success) {} |
199 |
+ |
assertFalse(Thread.interrupted()); |
200 |
|
}}); |
201 |
|
|
202 |
|
await(pleaseInterrupt); |
203 |
< |
assertThreadStaysAlive(t); |
203 |
> |
assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
204 |
|
t.interrupt(); |
205 |
|
awaitTermination(t); |
206 |
|
} |
283 |
|
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
284 |
|
|
285 |
|
await(pleaseInterrupt); |
286 |
< |
assertThreadStaysAlive(t); |
286 |
> |
assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
287 |
|
t.interrupt(); |
288 |
|
awaitTermination(t); |
289 |
|
} |