jdk/src/share/classes/java/util/concurrent/ArrayBlockingQueue.java
changeset 21278 ef8a3a2a72f2
parent 19428 83f87aff7b07
equal deleted inserted replaced
21277:bd380b80f9ea 21278:ef8a3a2a72f2
   944             if (head == null)   // no more iterators to track
   944             if (head == null)   // no more iterators to track
   945                 itrs = null;
   945                 itrs = null;
   946         }
   946         }
   947 
   947 
   948         /**
   948         /**
   949          * Called whenever an interior remove (not at takeIndex) occured.
   949          * Called whenever an interior remove (not at takeIndex) occurred.
   950          *
   950          *
   951          * Notifies all iterators, and expunges any that are now stale.
   951          * Notifies all iterators, and expunges any that are now stale.
   952          */
   952          */
   953         void removedAt(int removedIndex) {
   953         void removedAt(int removedIndex) {
   954             for (Node o = null, p = head; p != null;) {
   954             for (Node o = null, p = head; p != null;) {
  1303                 distance += length;
  1303                 distance += length;
  1304             return distance;
  1304             return distance;
  1305         }
  1305         }
  1306 
  1306 
  1307         /**
  1307         /**
  1308          * Called whenever an interior remove (not at takeIndex) occured.
  1308          * Called whenever an interior remove (not at takeIndex) occurred.
  1309          *
  1309          *
  1310          * @return true if this iterator should be unlinked from itrs
  1310          * @return true if this iterator should be unlinked from itrs
  1311          */
  1311          */
  1312         boolean removedAt(int removedIndex) {
  1312         boolean removedAt(int removedIndex) {
  1313             // assert lock.getHoldCount() == 1;
  1313             // assert lock.getHoldCount() == 1;