refactoring

2 years ago · 2fa5bc6d64
parent 44ca112260
commit 2fa5bc6d64
1 changed files with 3 additions and 0 deletions
--- a/redisson/src/main/java/org/redisson/RedissonIdGenerator.java
+++ b/redisson/src/main/java/org/redisson/RedissonIdGenerator.java
@ -101,6 +101,9 @@ public class RedissonIdGenerator extends RedissonExpirable implements RIdGenerat
            } else {
                counter.incrementAndGet();
                isWorkerActive.set(false);
+                if (!queue.isEmpty()) {
+                    startIdRequestsHandle();
+                }
            }
        } else {
            RFuture<List<Object>> future = commandExecutor.evalWriteAsync(getRawName(), LongCodec.INSTANCE, RedisCommands.EVAL_LIST,