c++ - 如何在 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()，您可以从另一个线程取消。