# | Line 808 | Line 808 | public class SynchronousQueue<E> extends | |
---|---|---|
808 | public void put(E o) throws InterruptedException { | |
809 | if (o == null) throw new NullPointerException(); | |
810 | if (transferer.transfer(o, false, 0) == null) { | |
811 | < | Thread.interrupted(); |
811 | > | Thread.interrupted(); |
812 | throw new InterruptedException(); | |
813 | < | } |
813 | > | } |
814 | } | |
815 | ||
816 | /** | |
# | Line 857 | Line 857 | public class SynchronousQueue<E> extends | |
857 | Object e = transferer.transfer(null, false, 0); | |
858 | if (e != null) | |
859 | return (E)e; | |
860 | < | Thread.interrupted(); |
860 | > | Thread.interrupted(); |
861 | throw new InterruptedException(); | |
862 | } | |
863 |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |