# | Line 267 | Line 267 | public abstract class BlockingQueueTest | |
---|---|---|
267 | }}); | |
268 | ||
269 | await(threadStarted); | |
270 | < | assertThreadStaysAlive(t); |
270 | > | assertThreadBlocks(t, Thread.State.WAITING); |
271 | t.interrupt(); | |
272 | awaitTermination(t); | |
273 | } | |
# | Line 308 | Line 308 | public abstract class BlockingQueueTest | |
308 | }}); | |
309 | ||
310 | await(threadStarted); | |
311 | < | assertThreadStaysAlive(t); |
311 | > | assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
312 | t.interrupt(); | |
313 | awaitTermination(t); | |
314 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |