grpc 报错 At least one of the completion queues must be frequently polled 如何改进, 给出代码

以下是一个简单的gRPC服务器示例代码，其中包含了正确处理CQ的示例：

import grpc
from concurrent import futures

import my_service_pb2
import my_service_pb2_grpc

class MyService(my_service_pb2_grpc.MyServiceServicer):
    def MyMethod(self, request, context):
        # Handle request
        response = my_service_pb2.Response()
        return response

def serve():
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    my_service_pb2_grpc.add_MyServiceServicer_to_server(MyService(), server)
    server.add_insecure_port('[::]:50051')
    server.start()

    try:
        while True:
            # Poll CQs frequently
            time.sleep(1)
            server._completion_queue.poll(0)
            server._callback_groups[0].poll(0)
    except KeyboardInterrupt:
        server.stop(0)

if __name__ == '__main__':
    serve()

在上面的代码中，我们使用了Python的`time`模块来定期调用gRPC服务器的两个CQ（`server._completion_queue`和`server._callback_groups[0]`）的`poll()`方法。这样可以确保及时处理异步操作完成时的通知，从而避免了"At least one of the completion queues must be frequently polled"错误的发生。

此外，我们还使用了gRPC提供的ThreadPoolExecutor来处理请求。这样可以让服务器在处理多个请求时更加高效和稳定。