# | Line 208 | Line 208 | public class SynchronousQueueTest extend | |
---|---|---|
208 | ||
209 | pleaseInterrupt.countDown(); | |
210 | try { | |
211 | < | q.offer(new Object(), LONG_DELAY_MS, MILLISECONDS); |
211 | > | q.offer(new Object(), LONGER_DELAY_MS, MILLISECONDS); |
212 | shouldThrow(); | |
213 | } catch (InterruptedException success) {} | |
214 | assertFalse(Thread.interrupted()); | |
215 | – | |
216 | – | assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
215 | }}); | |
216 | ||
217 | await(pleaseInterrupt); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |