src/share/classes/java/util/concurrent/DelayQueue.java

Print this page

        

*** 529,539 **** lastRet = -1; // Traverse underlying queue to find == element, // not just a .equals element. lock.lock(); try { ! for (Iterator it = q.iterator(); it.hasNext(); ) { if (it.next() == x) { it.remove(); return; } } --- 529,539 ---- lastRet = -1; // Traverse underlying queue to find == element, // not just a .equals element. lock.lock(); try { ! for (Iterator<E> it = q.iterator(); it.hasNext(); ) { if (it.next() == x) { it.remove(); return; } }