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

*** 330,340 ****
      public void put(E e) throws InterruptedException {
          if (e == null) throw new NullPointerException();
          // Note: convention in all put/take/etc is to preset local var
          // holding count negative to indicate failure unless set.
          int c = -1;
!         Node<E> node = new Node(e);
          final ReentrantLock putLock = this.putLock;
          final AtomicInteger count = this.count;
          putLock.lockInterruptibly();
          try {
              /*
--- 330,340 ----
      public void put(E e) throws InterruptedException {
          if (e == null) throw new NullPointerException();
          // Note: convention in all put/take/etc is to preset local var
          // holding count negative to indicate failure unless set.
          int c = -1;
!         Node<E> node = new Node<E>(e);
          final ReentrantLock putLock = this.putLock;
          final AtomicInteger count = this.count;
          putLock.lockInterruptibly();
          try {
              /*
*** 410,420 ****
          if (e == null) throw new NullPointerException();
          final AtomicInteger count = this.count;
          if (count.get() == capacity)
              return false;
          int c = -1;
!         Node<E> node = new Node(e);
          final ReentrantLock putLock = this.putLock;
          putLock.lock();
          try {
              if (count.get() < capacity) {
                  enqueue(node);
--- 410,420 ----
          if (e == null) throw new NullPointerException();
          final AtomicInteger count = this.count;
          if (count.get() == capacity)
              return false;
          int c = -1;
!         Node<E> node = new Node<E>(e);
          final ReentrantLock putLock = this.putLock;
          putLock.lock();
          try {
              if (count.get() < capacity) {
                  enqueue(node);
*** 726,735 ****
--- 726,737 ----
      public int drainTo(Collection<? super E> c, int maxElements) {
          if (c == null)
              throw new NullPointerException();
          if (c == this)
              throw new IllegalArgumentException();
+         if (maxElements <= 0)
+             return 0;
          boolean signalNotFull = false;
          final ReentrantLock takeLock = this.takeLock;
          takeLock.lock();
          try {
              int n = Math.min(maxElements, count.get());