639 |
|
assertEquals(0, q.take()); |
640 |
|
|
641 |
|
await(pleaseInterrupt); |
642 |
< |
assertThreadStaysAlive(t); |
642 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
643 |
|
t.interrupt(); |
644 |
|
awaitTermination(t); |
645 |
|
assertEquals(0, q.remainingCapacity()); |
926 |
|
}}); |
927 |
|
|
928 |
|
await(threadStarted); |
929 |
< |
assertThreadStaysAlive(t); |
929 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
930 |
|
t.interrupt(); |
931 |
|
awaitTermination(t); |
932 |
|
} |
967 |
|
}}); |
968 |
|
|
969 |
|
await(threadStarted); |
970 |
< |
assertThreadStaysAlive(t); |
970 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
971 |
|
t.interrupt(); |
972 |
|
awaitTermination(t); |
973 |
|
} |