diff --git a/src/main/java/io/github/dsheirer/sample/buffer/AbstractReusableBuffer.java b/src/main/java/io/github/dsheirer/sample/buffer/AbstractReusableBuffer.java index 77fbaf2e..c7085f3d 100644 --- a/src/main/java/io/github/dsheirer/sample/buffer/AbstractReusableBuffer.java +++ b/src/main/java/io/github/dsheirer/sample/buffer/AbstractReusableBuffer.java @@ -93,7 +93,7 @@ public abstract class AbstractReusableBuffer * * This method is thread-safe. */ - public void decrementUserCount() + public synchronized void decrementUserCount() { if(mUserCount.decrementAndGet() <= 0) { @@ -104,7 +104,7 @@ public abstract class AbstractReusableBuffer /** * Sends this buffer back to the owning buffer queue for reuse */ - private void recycle() + private synchronized void recycle() { prepareForRecycle();