如何在 gRPC 异步服务中使用共享完成队列

Question

您好，我正在尝试实现 DBMS 多线程 gRPC 异步服务。现在我坚持使用共享完成队列。我最初保存每个线程启动的 RPC 调用的标签，并根据 cq.Next() 的 rpc 调用返回检查标签，以确保我有正确的线程来检查回复。但是，我从Confusion around CompletionQueue in an async C++ client 发现每个标签只会从 cq 中出来一次。我想知道让多个线程共享同一个 cq 的最佳方法是什么？我希望每个线程能够只处理它启动的 RPC 调用，并且我不希望一个线程等待另一个线程创建的 RPC。这可能吗？怎么做？有没有办法遍历队列，只删除带有匹配标签的 RPC？我没有从之前的 stackoverflow 帖子中看到明确的解决方案。

Answer 1

我认为completion queue 和thread 可以有两种常用方法

1. 多个completion queue和多个threads，每个completion queue用于一个RPC，一个thread专注于一个completion queue
2. 一个completion queue和多个threads，每个thread调用completion_queue.Next()

但如果你想让它们混合，这意味着你需要添加另一个middleware 来将事件分配给特定线程。例如，初始化工作时，将tag记录在一个map中，调用cq.Next()时，可以查看map找到目标thread。但我找不到这种方式的任何好处。