198 |
|
long startTime = System.nanoTime(); |
199 |
|
assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS)); |
200 |
|
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
201 |
+ |
|
202 |
+ |
Thread.currentThread().interrupt(); |
203 |
+ |
try { |
204 |
+ |
q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); |
205 |
+ |
shouldThrow(); |
206 |
+ |
} catch (InterruptedException success) {} |
207 |
+ |
assertFalse(Thread.interrupted()); |
208 |
+ |
|
209 |
|
pleaseInterrupt.countDown(); |
210 |
|
try { |
211 |
|
q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); |