时间限制器不会中断线程

Question

我在我的项目中使用resilience4j Timelimiter。

如果请求花费的时间超过 10 秒，时间限制器会抛出错误，但不会中断线程。

当调用来自邮递员时，我已经进行了调试和测试，在邮递员中10秒后它显示异常，但线程仍然执行该方法，之后添加了一些打印语句并且它也执行了。

如何在resilience4j中10秒后取消或中断线程。

class A {
TimeLimiterConfig config = TimeLimiterConfig.custom().cancelRunningFuture(true)
      .timeoutDuration(Duration.ofMillis(TimeLimit)).build();

TimeLimiterRegistry timeLimiterRegistry = TimeLimiterRegistry.of(config);

TimeLimiter timeLimiter = timeLimiterRegistry.timeLimiter("APITimelimiter", config);


public Response someMethod() throws Exception {
try {
  timeLimiter.executeFutureSupplier(() -> CompletableFuture.supplyAsync(() -> {
            return getData();
          }));
} catch (Exception e) {
      logger.error("Request has crossed the execution time of " + TimeLimit
          + " seconds");
      throw new Exception("Your request has crossed the execution time of "+ TimeLimit+" seconds.");
    }
}

public UserData getData() {
String jsonData = "";
return jsonData;
}
}

Answer 1

TimeLimiter 无法取消 CompletableFuture。请参阅 @TimeLimiter 超时慢速方法但不取消运行 future #905 指出，即：CompletableFuture 中有限的 cancel() 不是一个错误，而是一个设计决策。 CompletableFuture 本身并不绑定到任何线程，而 Future 几乎总是代表后台任务。