Fixed - AsyncSemaphore counter field should be volatile. #2398

5 years ago · 8e74c0e9f6
parent 7bb7e1066b
commit 8e74c0e9f6
1 changed files with 1 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/pubsub/AsyncSemaphore.java
+++ b/redisson/src/main/java/org/redisson/pubsub/AsyncSemaphore.java
@ -76,7 +76,7 @@ public class AsyncSemaphore {
        
    }
    
-    private int counter;
+    private volatile int counter;
    private final Set<Entry> listeners = new LinkedHashSet<Entry>();

    public AsyncSemaphore(int permits) {