gRPC 服务器可以立即回收 DEADLINE_EXCEEDED 线程吗？

Question

这样说对吗 - java gRPC 服务器线程即使在 DEADLINE 时间之后仍然会运行。但是，gRPC 服务器将停止/阻止该线程仅在 DEADLINE 时间过后进行任何后续 gRPC 调用？

如果以上是正确的陈述，那么有没有办法停止/阻止线程进行任何 Redis / DB 调用以及已超过 DEADLINE 时间的线程？或者一旦超过 DEADLINE 时间，立即中断线程？

Answer 1

这样说对吗 - java gRPC 服务器线程即使在 DEADLINE 时间之后仍然会运行。

正确。 Java 没有提供任何真正的替代方案。

但是，gRPC 服务器将停止/阻止该线程仅在 DEADLINE 时间过后进行任何后续 gRPC 调用？

主要是。传出的 gRPC 调用遵守 io.grpc.Context，这意味着会传播截止日期和取消（除非您未能将 Context 传播到另一个线程或使用 Context.fork()）。

如果以上是正确的陈述，那么有没有办法停止/阻止线程进行任何 Redis / DB 调用以及已超过 DEADLINE 时间的线程？或者一旦超过了DEADLINE时间，立即中断线程？

您可以通过Context.addListener() 收听上下文取消。 gRPC 服务端会在截止期限到期并且客户端取消 RPC 时取消 Context。此通知是取消传出 RPC 的方式。

我会注意到线程中断有点涉及在不竞争的情况下执行。如果您想要中断并且还没有Future，我建议将您的工作包装在FutureTask 中（并且只需在当前线程上调用FutureTask.run()）以获得其非活泼的cancel(true) 实现。

final FutureTask<Void> future = new FutureTask<Void>(work, null);
Context current = Context.current();
CancellationListener listener = new CancellationListener() {
  @Override public void cancelled(Context context) {
    future.cancel(true);
  }
};
current.addListener(listener);
future.run();
current.removeListener(listener);

Answer 2

您可以在进行 Redis / DB 查询之前检查Context.isCancelled()，如果有，则抛出StatusException(CANCELLED)。