[dubbo] branch 3.0 updated: TimeoutCheckTask should be cancelled when DefaultFuture2 has been cancelled (#8901)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guohao pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new 0643a7c  TimeoutCheckTask should be cancelled when DefaultFuture2 has been cancelled (#8901)
0643a7c is described below

commit 0643a7ce7e8af1e469ff76a0d5624a28c5a17da4
Author: earthchen <yo...@duobei.com>
AuthorDate: Fri Sep 24 14:58:36 2021 +0800

    TimeoutCheckTask should be cancelled when DefaultFuture2 has been cancelled (#8901)
---
 .../java/org/apache/dubbo/remoting/exchange/support/DefaultFuture2.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture2.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture2.java
index 8268093..2e995ee 100644
--- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture2.java
+++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture2.java
@@ -163,6 +163,7 @@ public class DefaultFuture2 extends CompletableFuture<Object> {
         errorResult.setErrorMessage("request future has been canceled.");
         this.doReceived(errorResult);
         FUTURES.remove(request.getId());
+        timeoutCheckTask.cancel();
         return true;
     }