[cvs] / jsr166 / src / main / java / util / concurrent / SynchronousQueue.java Repository:
ViewVC logotype

Diff of /jsr166/src/main/java/util/concurrent/SynchronousQueue.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.63, Fri Aug 19 23:36:50 2005 UTC revision 1.64, Sat Feb 11 00:03:36 2006 UTC
# Line 807  Line 807 
807       */       */
808      public void put(E o) throws InterruptedException {      public void put(E o) throws InterruptedException {
809          if (o == null) throw new NullPointerException();          if (o == null) throw new NullPointerException();
810          if (transferer.transfer(o, false, 0) == null)          if (transferer.transfer(o, false, 0) == null) {
811                Thread.interrupted();
812              throw new InterruptedException();              throw new InterruptedException();
813      }      }
814        }
815    
816      /**      /**
817       * Inserts the specified element into this queue, waiting if necessary       * Inserts the specified element into this queue, waiting if necessary
# Line 855  Line 857 
857          Object e = transferer.transfer(null, false, 0);          Object e = transferer.transfer(null, false, 0);
858          if (e != null)          if (e != null)
859              return (E)e;              return (E)e;
860            Thread.interrupted();
861          throw new InterruptedException();          throw new InterruptedException();
862      }      }
863    
Legend:
Removed from v.1.63  
changed lines
  Added in v.1.64
Doug Lea
 ViewVC Help
Powered by ViewVC 1.0.8