Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-13 13:35:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-908: Replace lock by CAS to avoid deadlock

Browse Source 
(cherry picked from commit 4622066323e9ba5af0777d0c7315389ee8f647f5)
This commit is contained in:
Ulf Lilleengen 2017-02-15 15:49:11 +01:00 committed by Clebert Suconic
parent be37020964
commit b0585329b4
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
private static final class OverSizedRunnable implements Runnable {
private boolean ran;
private final AtomicBoolean ran = new AtomicBoolean(false);
private final Runnable runnable;
@ -646,11 +646,9 @@ public class PagingStoreImpl implements PagingStore {
}
@Override
public synchronized void run() {
if (!ran) {
public void run() {
if (ran.compareAndSet(false, true)) {
runnable.run();
ran = true;
}
}
}