我正在尝试(失败)将 gRPC(grpc.io)与线程一起使用。
我希望在收到请求后将其扩展到一个线程并通过该线程进行响应,而不需要 gRPC 的“返回”部分。
这是我的方法:
def CriaItem(self, request, context):
chave = request.chave
valor = request.valor
validacao = self.configs.valida_chave(chave)
if validacao[0]:
self.queue1.enqueue((comandos['create'], chave, valor, context))
else:
stub = self.cria_stub(validacao[1])
self.queue4.enqueue((comandos['create'], chave, valor, context, stub))
出队过程将发生在线程内。之后,我想将一些值返回给请求者。
有没有办法在不使用异步关键字的情况下做到这一点?