ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/LinkedBlockingQueue.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/LinkedBlockingQueue.java (file contents):
Revision 1.48 by jsr166, Sun May 28 23:36:29 2006 UTC vs.
Revision 1.49 by jsr166, Sun May 18 23:47:56 2008 UTC

# Line 584 | Line 584 | public class LinkedBlockingQueue<E> exte
584          fullyLock();
585          try {
586              head.next = null;
587 <            assert head.item == null;
588 <            last = head;
587 >            assert head.item == null;
588 >            last = head;
589              if (count.getAndSet(0) == capacity)
590                  notFull.signalAll();
591          } finally {
# Line 609 | Line 609 | public class LinkedBlockingQueue<E> exte
609          try {
610              first = head.next;
611              head.next = null;
612 <            assert head.item == null;
613 <            last = head;
612 >            assert head.item == null;
613 >            last = head;
614              if (count.getAndSet(0) == capacity)
615                  notFull.signalAll();
616          } finally {
# Line 649 | Line 649 | public class LinkedBlockingQueue<E> exte
649              }
650              if (n != 0) {
651                  head.next = p;
652 <                assert head.item == null;
653 <                if (p == null)
654 <                    last = head;
652 >                assert head.item == null;
653 >                if (p == null)
654 >                    last = head;
655                  if (count.getAndAdd(-n) == capacity)
656                      notFull.signalAll();
657              }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines