如何在 C++ 中取消 grpc::ClientReader 的 Read() 调用？

Question

我有代码使用 grpc::ClientReader 从 grpc::Server 请求数据流。主循环如下所示，并在单独的任务中运行。我需要在析构函数时关闭任务，但 Read() 方法被阻塞。我似乎无法对 mcReader 做任何事情来让它停止阻塞。我宁愿不使用截止日期，因为数据不完全是周期性的，并且使其足够大以执行 Antyhign 仍然会阻塞很长时间。我应该怎么办？

while (mcReader->Read(&dataProductWrapper) && meTasksRunning) 
{
      // Do some work.
}

Answer 1

所以环顾四周我明白了。使用传递到 RPC 调用的 grpc::ClientContext，您可以调用 grpc::ClientContext::TryCancel() ，您可以从另一个线程取消。