Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #1018

This commit is contained in:
Clebert Suconic 2017-02-15 10:26:02 -05:00
parent 6474c41ce6 4622066323
commit ab122376e6
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
View File

@ -637,7 +637,7 @@ public class PagingStoreImpl implements PagingStore {
// To be used when the memory is oversized either by local settings or global settings on blocking addresses // To be used when the memory is oversized either by local settings or global settings on blocking addresses
private static final class OverSizedRunnable implements Runnable { private static final class OverSizedRunnable implements Runnable {
private boolean ran; private final AtomicBoolean ran = new AtomicBoolean(false);
private final Runnable runnable; private final Runnable runnable;
@ -646,11 +646,9 @@ public class PagingStoreImpl implements PagingStore {
} }
@Override @Override
public synchronized void run() { public void run() {
if (!ran) { if (ran.compareAndSet(false, true)) {
runnable.run(); runnable.run();
ran = true;
} }
} }
} }