ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/main/java/util/concurrent/LinkedTransferQueue.java

Comparing jsr166/src/main/java/util/concurrent/LinkedTransferQueue.java (file contents):
Revision 1.76 by jsr166, Wed Dec 31 07:54:14 2014 UTC vs.
Revision 1.77 by jsr166, Wed Dec 31 08:20:26 2014 UTC

#	Line 680 | Line 680 | public class LinkedTransferQueue<E> exte
680		return itemE;
681		}
682		else if (w.isInterrupted() || (timed && nanos <= 0)) {
683	<	unsplice(pred, s);           // try to unlink and cancel
684	<	if (s.casItem(e, s))         // return normally if lost CAS
685	<	return e;
683	>	unsplice(pred, s);            // try to unlink and cancel
684	>	if (s.casItem(e, s))          // return normally if lost CAS
685	>	return e;
686		}
687	<	else if (spins < 0) {            // establish spins at/near front
687	>	else if (spins < 0) {             // establish spins at/near front
688		if ((spins = spinsFor(pred, s.isData)) > 0)
689		randomYields = ThreadLocalRandom.current();
690		}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines