voice = yield threads.deferToThread(self.read_voice_from_url, responses.get("audioPath"))
threads.deferToThread是twisted框架里的异步回调,但我要使用回调结果值,就用yield接收了回调结果。
self.read_voice_from_url 是一个耗时操作,单独运行只需要十几毫秒,当使用yield接收异步返回值时,并发时,时间竟然增加了几十倍,请问什么原因引起的,怎么解决?
yield threads.deferToThread 这样就是变成同步操作了,一直等到read_voice_from_url执行完的结果,然后responses.get("audioPath")进行处理了,才返回给你,时间自然变长了
result = threads.deferToThread(self.read_voice_from_url, responses.get("audioPath"))
...
// 做些别的事情 在需要返回的时候,再返回
yield result
看你怎么调用的 yield
如果是放在for循环里,那么就会把整个迭代全部走完。
但是如果你用 __next__(),它只执行到下一次yield出现就停止了,就快很多。
看下面的代码:
def h():
yield 1
print("执行一个耗时的代码")
yield 2
c = h()
print(c.__next__())
这段代码不会输出"执行一个耗时的代码"
再看
def h():
yield 1
print("执行一个耗时的代码")
yield 2
c = list(h())
print(c[0])
这样就会输出了,假设那个print是一个真的耗时很久的代码,那么后者就很慢了。
另外注意,如果是python 3.x,__next__要写成 next,没有下划线