如果我想这样的话可以吗: def consumer(q): global num global server_path while True: if not q.empty(): a = q.get() cd = crawler("",a) cd["img"]=sftp_upload_file(server_path,(os.path.join(os.getcwd()+pic_download(cd["img"],num)))) num+=1 #insertinto 是一个 aiomysql 的方法,一个异步插入的方法 insertinto(cd) else: break
1
ipwx 2017-10-18 23:20:36 +08:00
你可以定义一个 async def consumer(q)
|
2
linhanqiu OP @ipwx 多谢,我也刚刚想到,并且测试好了,可以这么用,不知道大神有没有用过 asyncio 加上 mulitprocessing 共用的情况
|
3
1314258 2017-10-18 23:27:21 +08:00
不能 await lambda x:x+1
lambda 不能 awaitable。 |