From 303cd6924f9a615a501989d58b6f3df4f21b242b Mon Sep 17 00:00:00 2001 From: ichenpeng Date: Mon, 11 Jul 2022 15:16:22 +0800 Subject: [PATCH] interrupt thread when InterruptedException occur (#10299) Co-authored-by: chenpeng --- .../main/java/org/apache/dubbo/rpc/protocol/AbstractInvoker.java | 1 + 1 file changed, 1 insertion(+) diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AbstractInvoker.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AbstractInvoker.java index 71247a5523b..e1582febf9b 100644 --- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AbstractInvoker.java +++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AbstractInvoker.java @@ -266,6 +266,7 @@ private void waitForResultIfSync(AsyncRpcResult asyncResult, RpcInvocation invoc 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) {