@@ -493,6 +493,7 @@ public Iterator<E> descendingIterator() {
493493 * @throws NullPointerException if c is null
494494 * @throws IllegalArgumentException if c is this instance
495495 */
496+ @ Override
496497 public int drainTo (final Collection <? super E > c ) {
497498 return drainTo (c , Integer .MAX_VALUE );
498499 }
@@ -512,6 +513,7 @@ public int drainTo(final Collection<? super E> c) {
512513 * @throws NullPointerException if c is null
513514 * @throws IllegalArgumentException if c is this instance
514515 */
516+ @ Override
515517 public int drainTo (final Collection <? super E > collection , final int maxElements ) {
516518 Objects .requireNonNull (collection , "collection" );
517519 if (collection == this ) {
@@ -716,6 +718,7 @@ boolean offer(final E e, final Duration timeout) throws InterruptedException {
716718 * @throws InterruptedException if the thread is interrupted whilst waiting
717719 * for space
718720 */
721+ @ Override
719722 public boolean offer (final E e , final long timeout , final TimeUnit unit ) throws InterruptedException {
720723 return offerLast (e , timeout , unit );
721724 }
@@ -774,6 +777,7 @@ boolean offerFirst(final E e, final Duration timeout) throws InterruptedExceptio
774777 * @throws InterruptedException if the thread is interrupted whilst waiting
775778 * for space
776779 */
780+ @ Override
777781 public boolean offerFirst (final E e , final long timeout , final TimeUnit unit ) throws InterruptedException {
778782 return offerFirst (e , PoolImplUtils .toDuration (timeout , unit ));
779783 }
@@ -832,6 +836,7 @@ boolean offerLast(final E e, final Duration timeout) throws InterruptedException
832836 * @throws InterruptedException if the thread is interrupted whist waiting
833837 * for space
834838 */
839+ @ Override
835840 public boolean offerLast (final E e , final long timeout , final TimeUnit unit ) throws InterruptedException {
836841 return offerLast (e , PoolImplUtils .toDuration (timeout , unit ));
837842 }
@@ -893,6 +898,7 @@ E poll(final Duration timeout) throws InterruptedException {
893898 * @return the unlinked element
894899 * @throws InterruptedException if the current thread is interrupted
895900 */
901+ @ Override
896902 public E poll (final long timeout , final TimeUnit unit ) throws InterruptedException {
897903 return pollFirst (timeout , unit );
898904 }
@@ -941,6 +947,7 @@ E pollFirst(final Duration timeout) throws InterruptedException {
941947 * @return the unlinked element
942948 * @throws InterruptedException if the current thread is interrupted
943949 */
950+ @ Override
944951 public E pollFirst (final long timeout , final TimeUnit unit ) throws InterruptedException {
945952 return pollFirst (PoolImplUtils .toDuration (timeout , unit ));
946953 }
@@ -990,6 +997,7 @@ E pollLast(final Duration timeout)
990997 * @return the unlinked element
991998 * @throws InterruptedException if the current thread is interrupted
992999 */
1000+ @ Override
9931001 public E pollLast (final long timeout , final TimeUnit unit )
9941002 throws InterruptedException {
9951003 return pollLast (PoolImplUtils .toDuration (timeout , unit ));
@@ -1024,6 +1032,7 @@ public void push(final E e) {
10241032 * @throws InterruptedException if the thread is interrupted whilst waiting
10251033 * for space
10261034 */
1035+ @ Override
10271036 public void put (final E e ) throws InterruptedException {
10281037 putLast (e );
10291038 }
@@ -1037,6 +1046,7 @@ public void put(final E e) throws InterruptedException {
10371046 * @throws InterruptedException if the thread is interrupted whilst waiting
10381047 * for space
10391048 */
1049+ @ Override
10401050 public void putFirst (final E e ) throws InterruptedException {
10411051 Objects .requireNonNull (e , "e" );
10421052 lock .lock ();
@@ -1058,6 +1068,7 @@ public void putFirst(final E e) throws InterruptedException {
10581068 * @throws InterruptedException if the thread is interrupted whilst waiting
10591069 * for space
10601070 */
1071+ @ Override
10611072 public void putLast (final E e ) throws InterruptedException {
10621073 Objects .requireNonNull (e , "e" );
10631074 lock .lock ();
@@ -1108,6 +1119,7 @@ private void readObject(final ObjectInputStream s) throws IOException, ClassNotF
11081119 *
11091120 * @return The number of additional elements the queue is able to accept
11101121 */
1122+ @ Override
11111123 public int remainingCapacity () {
11121124 lock .lock ();
11131125 try {
@@ -1286,6 +1298,7 @@ public int size() {
12861298 * @return the unlinked element
12871299 * @throws InterruptedException if the current thread is interrupted
12881300 */
1301+ @ Override
12891302 public E take () throws InterruptedException {
12901303 return takeFirst ();
12911304 }
@@ -1297,6 +1310,7 @@ public E take() throws InterruptedException {
12971310 * @return the unlinked element
12981311 * @throws InterruptedException if the current thread is interrupted
12991312 */
1313+ @ Override
13001314 public E takeFirst () throws InterruptedException {
13011315 lock .lock ();
13021316 try {
@@ -1317,6 +1331,7 @@ public E takeFirst() throws InterruptedException {
13171331 * @return the unlinked element
13181332 * @throws InterruptedException if the current thread is interrupted
13191333 */
1334+ @ Override
13201335 public E takeLast () throws InterruptedException {
13211336 lock .lock ();
13221337 try {
0 commit comments