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

Question

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

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

Answer 1

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