我对Python的await有疑问,我举了一个例子,它试图使用await从未来的obj中获取结果。
import time
import asyncio
import time
import random
import threading
db = {
"yzh": "pig",
"zhh": "big pig"
}
loop = asyncio.get_event_loop()
def _get_redis(username, clb):
def foo():
data = db[username]
time.sleep(0.1)
print("start clb")
clb(data)
t1 = threading.Thread(target=foo)
t1.start()
def get_redis(username):
print("start get redis")
myfuture = asyncio.Future()
def clb(result):
print("clb call")
myfuture.set_result(result)
_get_redis(username, clb)
return myfuture
async def main():
print("start main")
data = await get_redis("yzh")
print("data is {}".format(data))
loop.run_until_complete(asyncio.ensure_future(main()))
loop.close()我得到了没有未来结果的输出:
start main
start get redis
start clb
clb call我应该如何使用await来获得未来的结果呢?我尝试了很多次。谢谢你的帮助。
https://stackoverflow.com/questions/44528433
复制相似问题