future(provider): future:server support timeout interrupt

trpc-group · Dec 19, 2024 · e2b2d2b · e2b2d2b
1 parent a37af5e
commit e2b2d2b
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git a/trpc-core/src/main/java/com/tencent/trpc/core/common/config/ProviderConfig.java b/trpc-core/src/main/java/com/tencent/trpc/core/common/config/ProviderConfig.java
@@ -58,7 +58,7 @@ public class ProviderConfig<T> implements Cloneable {
     protected int requestTimeout;
 
     /**
-     * Enable execute timeout interrupt.
+     * Whether to enable execute timeout interrupt.
      */
     @ConfigProperty(value="false",type=Boolean.class,override = true)
     protected Boolean enableTimeoutInterrupt;

diff --git a/trpc-core/src/main/java/com/tencent/trpc/core/common/config/ServerConfig.java b/trpc-core/src/main/java/com/tencent/trpc/core/common/config/ServerConfig.java
@@ -74,6 +74,11 @@ public class ServerConfig {
      */
     @ConfigProperty(value = "false", type = Boolean.class)
     protected Boolean enableLinkTimeout;
+    /**
+     * Whether to enable execute timeout interrupt.
+     */
+    @ConfigProperty(value="false",type=Boolean.class)
+    protected Boolean enableTimeoutInterrupt;
     /**
      * Whether to disable default filters:
      * <p>{@link com.tencent.trpc.core.filter.ProviderInvokerHeadFilter}</p>
@@ -413,4 +418,13 @@ public void setRunListeners(List<String> runListeners) {
         this.runListeners = runListeners;
     }
 
+    public Boolean getEnableTimeoutInterrupt() {
+        return enableTimeoutInterrupt;
+    }
+
+    public void setEnableTimeoutInterrupt(Boolean enableTimeoutInterrupt) {
+        checkFiledModifyPrivilege();
+        this.enableTimeoutInterrupt = enableTimeoutInterrupt;
+    }
+
 }
diff --git a/trpc-core/src/main/java/com/tencent/trpc/core/common/config/ServiceConfig.java b/trpc-core/src/main/java/com/tencent/trpc/core/common/config/ServiceConfig.java
@@ -145,7 +145,7 @@ public class ServiceConfig extends BaseProtocolConfig {
     @ConfigProperty(value = "false", type = Boolean.class, override = true)
     protected Boolean enableLinkTimeout;
     /**
-     * Enable execute timeout interrupt.
+     * Whether to enable execute timeout interrupt.
      */
     @ConfigProperty(value="false",type=Boolean.class,override = true)
     protected Boolean enableTimeoutInterrupt;