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()); |
172 |
|
catch (InterruptedException e) { threadUnexpectedException(e); } |
173 |
|
|
174 |
|
await(pleaseInterrupt); |
175 |
< |
assertThreadStaysAlive(t); |
175 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
176 |
|
t.interrupt(); |
177 |
|
awaitTermination(t); |
178 |
|
assertEquals(0, q.remainingCapacity()); |
199 |
|
}}); |
200 |
|
|
201 |
|
await(pleaseInterrupt); |
202 |
< |
assertThreadStaysAlive(t); |
202 |
> |
assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
203 |
|
t.interrupt(); |
204 |
|
awaitTermination(t); |
205 |
|
} |