diff --git a/redisson/src/main/java/org/redisson/RedissonLock.java b/redisson/src/main/java/org/redisson/RedissonLock.java index 26be95f0e..f953d8715 100644 --- a/redisson/src/main/java/org/redisson/RedissonLock.java +++ b/redisson/src/main/java/org/redisson/RedissonLock.java @@ -342,7 +342,9 @@ public class RedissonLock extends RedissonExpirable implements RLock { protected RFuture evalWriteAsync(String key, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params) { CommandBatchService executorService = createCommandBatchService(); RFuture result = executorService.evalWriteAsync(key, codec, evalCommandType, script, keys, params); - executorService.executeAsync(); + if (!(commandExecutor instanceof CommandBatchService)) { + executorService.executeAsync(); + } return result; }