ViewVC Help

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

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

Comparing jsr166/src/main/java/util/concurrent/LinkedBlockingQueue.java (file contents):
Revision 1.59 by jsr166, Thu Apr 14 23:05:50 2011 UTC vs.
Revision 1.60 by jsr166, Fri Jun 3 02:28:05 2011 UTC

#	Line 303 | Line 303 | public class LinkedBlockingQueue<E> exte
303		// Note: convention in all put/take/etc is to preset local var
304		// holding count negative to indicate failure unless set.
305		int c = -1;
306	<	Node<E> node = new Node(e);
306	>	Node<E> node = new Node<E>(e);
307		final ReentrantLock putLock = this.putLock;
308		final AtomicInteger count = this.count;
309		putLock.lockInterruptibly();
#	Line 383 | Line 383 | public class LinkedBlockingQueue<E> exte
383		if (count.get() == capacity)
384		return false;
385		int c = -1;
386	<	Node<E> node = new Node(e);
386	>	Node<E> node = new Node<E>(e);
387		final ReentrantLock putLock = this.putLock;
388		putLock.lock();
389		try {

Diff Legend

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