# | Line 159 | Line 159 | public class SynchronousQueueTest extend | |
---|---|---|
159 | pleaseTake.countDown(); | |
160 | q.put(one); | |
161 | ||
162 | + | Thread.currentThread().interrupt(); |
163 | + | try { |
164 | + | q.put(99); |
165 | + | shouldThrow(); |
166 | + | } catch (InterruptedException success) {} |
167 | + | assertFalse(Thread.interrupted()); |
168 | + | |
169 | pleaseInterrupt.countDown(); | |
170 | try { | |
171 | q.put(99); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |