diff --git a/google-cloud-storage/src/main/java/com/google/cloud/storage/AsyncAppendingQueue.java b/google-cloud-storage/src/main/java/com/google/cloud/storage/AsyncAppendingQueue.java index 3a9e01c882..a00c8d0359 100644 --- a/google-cloud-storage/src/main/java/com/google/cloud/storage/AsyncAppendingQueue.java +++ b/google-cloud-storage/src/main/java/com/google/cloud/storage/AsyncAppendingQueue.java @@ -90,7 +90,7 @@ private AsyncAppendingQueue( lock = new ReentrantLock(); } - synchronized AsyncAppendingQueue append(ApiFuture value) throws ShortCircuitException { + AsyncAppendingQueue append(ApiFuture value) throws ShortCircuitException { lock.lock(); try { checkState(state.isOpen(), "already closed"); @@ -124,7 +124,7 @@ T await() { } @Override - public synchronized void close() { + public void close() { lock.lock(); try { if (!state.isOpen()) {