This is an automated email from the ASF dual-hosted git repository. ggregory pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/commons-pool.git
commit 3c37e5ab783edd432d9162d21cb1f45567f7792e Author: Gary Gregory <gardgreg...@gmail.com> AuthorDate: Thu Jun 3 09:40:24 2021 -0400 Use longer line length. --- .../commons/pool2/impl/LinkedBlockingDeque.java | 20 +++++++------------- 1 file changed, 7 insertions(+), 13 deletions(-) diff --git a/src/main/java/org/apache/commons/pool2/impl/LinkedBlockingDeque.java b/src/main/java/org/apache/commons/pool2/impl/LinkedBlockingDeque.java index bdda64f..00f4b18 100644 --- a/src/main/java/org/apache/commons/pool2/impl/LinkedBlockingDeque.java +++ b/src/main/java/org/apache/commons/pool2/impl/LinkedBlockingDeque.java @@ -599,7 +599,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> public void interuptTakeWaiters() { lock.lock(); try { - lock.interruptWaiters(notEmpty); + lock.interruptWaiters(notEmpty); } finally { lock.unlock(); } @@ -695,8 +695,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> * @throws InterruptedException if the thread is interrupted whilst waiting * for space */ - boolean offer(final E e, final Duration timeout) - throws InterruptedException { + boolean offer(final E e, final Duration timeout) throws InterruptedException { return offerLast(e, timeout); } @@ -716,8 +715,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> * @throws InterruptedException if the thread is interrupted whilst waiting * for space */ - public boolean offer(final E e, final long timeout, final TimeUnit unit) - throws InterruptedException { + public boolean offer(final E e, final long timeout, final TimeUnit unit) throws InterruptedException { return offerLast(e, timeout, unit); } @@ -748,8 +746,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> * @throws InterruptedException if the thread is interrupted whilst waiting * for space */ - public boolean offerFirst(final E e, final Duration timeout) - throws InterruptedException { + public boolean offerFirst(final E e, final Duration timeout) throws InterruptedException { Objects.requireNonNull(e, "e"); long nanos = timeout.toNanos(); lock.lockInterruptibly(); @@ -780,8 +777,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> * @throws InterruptedException if the thread is interrupted whilst waiting * for space */ - public boolean offerFirst(final E e, final long timeout, final TimeUnit unit) - throws InterruptedException { + public boolean offerFirst(final E e, final long timeout, final TimeUnit unit) throws InterruptedException { return offerFirst(e, PoolImplUtils.toDuration(timeout, unit)); } @@ -812,8 +808,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> * @throws InterruptedException if the thread is interrupted whist waiting * for space */ - boolean offerLast(final E e, final Duration timeout) - throws InterruptedException { + boolean offerLast(final E e, final Duration timeout) throws InterruptedException { Objects.requireNonNull(e, "e"); long nanos = timeout.toNanos(); lock.lockInterruptibly(); @@ -1491,8 +1486,7 @@ class LinkedBlockingDeque<E> extends AbstractQueue<E> * {@code Object}) in the proper order, followed by a null * @param s the stream */ - private void writeObject(final java.io.ObjectOutputStream s) - throws java.io.IOException { + private void writeObject(final java.io.ObjectOutputStream s) throws java.io.IOException { lock.lock(); try { // Write out capacity and any hidden stuff