Interrupt current thread when InterruptException occur (#10164)

* throw InterruptedException in FailoverClusterInvoker * interrupt current thread when InterruptException occur
apache · Jul 11, 2022 · 787d26d · 787d26d
1 parent 3ec1bee
commit 787d26d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
@@ -61,6 +61,7 @@ public Result invoke(Invocation invocation) throws RpcException {
                 asyncResult.get(Integer.MAX_VALUE, TimeUnit.MILLISECONDS);
             }
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             throw new RpcException("Interrupted unexpectedly while waiting for remote result to return!  method: " +
                     invocation.getMethodName() + ", provider: " + getUrl() + ", cause: " + e.getMessage(), e);
         } catch (ExecutionException e) {