| # | Line 807 | Line 807 | public class SynchronousQueue<E> extends | |
|---|---|---|
| 807 | */ | |
| 808 | public void put(E o) throws InterruptedException { | |
| 809 | if (o == null) throw new NullPointerException(); | |
| 810 | < | if (transferer.transfer(o, false, 0) == null) |
| 810 | > | if (transferer.transfer(o, false, 0) == null) { |
| 811 | > | Thread.interrupted(); |
| 812 | throw new InterruptedException(); | |
| 813 | + | } |
| 814 | } | |
| 815 | ||
| 816 | /** | |
| # | Line 855 | 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(); |
| 861 | throw new InterruptedException(); | |
| 862 | } | |
| 863 | ||
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |