diff --git a/redisson/src/main/java/org/redisson/RedissonIdGenerator.java b/redisson/src/main/java/org/redisson/RedissonIdGenerator.java index 4d7c7b399..5b3b3cc3f 100644 --- 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> future = commandExecutor.evalWriteAsync(getRawName(), LongCodec.INSTANCE, RedisCommands.EVAL_LIST,