提交 113ba786 编写于 作者: N Nikita

refactoring

上级 7c668a06
......@@ -202,19 +202,16 @@ public class RedissonBitSet extends RedissonExpirable implements RBitSet {
@Override
public RFuture<Void> setAsync(long fromIndex, long toIndex, boolean value) {
if (value) {
return setAsync(fromIndex, toIndex);
CommandBatchService executorService = new CommandBatchService(commandExecutor.getConnectionManager());
for (long i = fromIndex; i < toIndex; i++) {
executorService.writeAsync(getName(), codec, RedisCommands.SETBIT_VOID, getName(), i, value ? 1 : 0);
}
return clearAsync(fromIndex, toIndex);
return executorService.executeAsyncVoid();
}
@Override
public RFuture<Void> clearAsync(long fromIndex, long toIndex) {
CommandBatchService executorService = new CommandBatchService(commandExecutor.getConnectionManager());
for (long i = fromIndex; i < toIndex; i++) {
executorService.writeAsync(getName(), codec, RedisCommands.SETBIT_VOID, getName(), i, 0);
}
return executorService.executeAsyncVoid();
return setAsync(fromIndex, toIndex, false);
}
@Override
......@@ -229,11 +226,7 @@ public class RedissonBitSet extends RedissonExpirable implements RBitSet {
@Override
public RFuture<Void> setAsync(long fromIndex, long toIndex) {
CommandBatchService executorService = new CommandBatchService(commandExecutor.getConnectionManager());
for (long i = fromIndex; i < toIndex; i++) {
executorService.writeAsync(getName(), codec, RedisCommands.SETBIT_VOID, getName(), i, 1);
}
return executorService.executeAsyncVoid();
return setAsync(fromIndex, toIndex, true);
}
@Override
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册