# | Line 196 | Line 196 | public class SynchronousQueueTest extend | |
---|---|---|
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); | |
# | Line 282 | Line 283 | public class SynchronousQueueTest extend | |
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 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |