refactoring

pull/2452/merge
Nikita Koksharov 5 years ago
parent 238c144365
commit c0f980bf57

@ -824,7 +824,7 @@ public class RedissonExecutorService implements RScheduledExecutorService {
List<Result> list = entry.getResponses().remove(requestId); List<Result> list = entry.getResponses().remove(requestId);
if (list != null) { if (list != null) {
for (Result result : list) { for (Result result : list) {
result.getScheduledFuture().cancel(true); result.getResponseTimeoutFuture().cancel(true);
} }
} }
if (entry.getResponses().isEmpty()) { if (entry.getResponses().isEmpty()) {

@ -142,7 +142,7 @@ public abstract class BaseRemoteProxy {
for (Iterator<Result> iterator = list.iterator(); iterator.hasNext();) { for (Iterator<Result> iterator = list.iterator(); iterator.hasNext();) {
Result result = iterator.next(); Result result = iterator.next();
if (result.getPromise() == responseFuture) { if (result.getPromise() == responseFuture) {
result.getScheduledFuture().cancel(true); result.getResponseTimeoutFuture().cancel(true);
iterator.remove(); iterator.remove();
} }
} }
@ -157,7 +157,7 @@ public abstract class BaseRemoteProxy {
} }
}); });
ScheduledFuture<?> future = commandExecutor.getConnectionManager().getGroup().schedule(new Runnable() { ScheduledFuture<?> responseTimeoutFuture = commandExecutor.getConnectionManager().getGroup().schedule(new Runnable() {
@Override @Override
public void run() { public void run() {
synchronized (responses) { synchronized (responses) {
@ -188,7 +188,7 @@ public abstract class BaseRemoteProxy {
entryResponses.put(requestId, list); entryResponses.put(requestId, list);
} }
Result res = new Result(responseFuture, future); Result res = new Result(responseFuture, responseTimeoutFuture);
if (insertFirst) { if (insertFirst) {
list.add(0, res); list.add(0, res);
} else { } else {
@ -243,7 +243,7 @@ public abstract class BaseRemoteProxy {
} }
promise = res.getPromise(); promise = res.getPromise();
res.getScheduledFuture().cancel(true); res.getResponseTimeoutFuture().cancel(true);
if (entry.getResponses().isEmpty()) { if (entry.getResponses().isEmpty()) {
responses.remove(responseQueueName, entry); responses.remove(responseQueueName, entry);

@ -33,20 +33,20 @@ public class ResponseEntry {
public static class Result { public static class Result {
private final RPromise<? extends RRemoteServiceResponse> promise; private final RPromise<? extends RRemoteServiceResponse> promise;
private final ScheduledFuture<?> scheduledFuture; private final ScheduledFuture<?> responseTimeoutFuture;
public Result(RPromise<? extends RRemoteServiceResponse> promise, ScheduledFuture<?> scheduledFuture) { public Result(RPromise<? extends RRemoteServiceResponse> promise, ScheduledFuture<?> responseTimeoutFuture) {
super(); super();
this.promise = promise; this.promise = promise;
this.scheduledFuture = scheduledFuture; this.responseTimeoutFuture = responseTimeoutFuture;
} }
public <T extends RRemoteServiceResponse> RPromise<T> getPromise() { public <T extends RRemoteServiceResponse> RPromise<T> getPromise() {
return (RPromise<T>) promise; return (RPromise<T>) promise;
} }
public ScheduledFuture<?> getScheduledFuture() { public ScheduledFuture<?> getResponseTimeoutFuture() {
return scheduledFuture; return responseTimeoutFuture;
} }
} }

Loading…
Cancel
Save