jdk/src/share/classes/java/util/concurrent/DelayQueue.java
changeset 11279 d9dab5ec5044
parent 9242 ef138d47df58
child 18767 6214297bf27d
equal deleted inserted replaced
11277:e3a1c90dd439 11279:d9dab5ec5044
   529             lastRet = -1;
   529             lastRet = -1;
   530             // Traverse underlying queue to find == element,
   530             // Traverse underlying queue to find == element,
   531             // not just a .equals element.
   531             // not just a .equals element.
   532             lock.lock();
   532             lock.lock();
   533             try {
   533             try {
   534                 for (Iterator it = q.iterator(); it.hasNext(); ) {
   534                 for (Iterator<E> it = q.iterator(); it.hasNext(); ) {
   535                     if (it.next() == x) {
   535                     if (it.next() == x) {
   536                         it.remove();
   536                         it.remove();
   537                         return;
   537                         return;
   538                     }
   538                     }
   539                 }
   539                 }