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.97 by jsr166, Sun Sep 20 17:03:23 2015 UTC vs.
Revision 1.98 by jsr166, Sat Oct 3 18:17:51 2015 UTC

# Line 351 | Line 351 | public class LinkedBlockingQueue<E> exte
351          putLock.lockInterruptibly();
352          try {
353              while (count.get() == capacity) {
354 <                if (nanos <= 0)
354 >                if (nanos <= 0L)
355                      return false;
356                  nanos = notFull.awaitNanos(nanos);
357              }
# Line 433 | Line 433 | public class LinkedBlockingQueue<E> exte
433          takeLock.lockInterruptibly();
434          try {
435              while (count.get() == 0) {
436 <                if (nanos <= 0)
436 >                if (nanos <= 0L)
437                      return null;
438                  nanos = notEmpty.awaitNanos(nanos);
439              }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines