如果我想这样的话可以吗: 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
推荐学习书目
› Learn Python the Hard Way
Python Sites
› PyPI - Python Package Index
› http://diveintopython.org/toc/index.html
› Pocoo
值得关注的项目
› PyPy
› Celery
› Jinja2
› Read the Docs
› gevent
› pyenv
› virtualenv
› Stackless Python
› Beautiful Soup
› 结巴中文分词
› Green Unicorn
› Sentry
› Shovel
› Pyflakes
› pytest
Python 编程
› pep8 Checker
Styles
› PEP 8
› Google Python Style Guide
› Code Style from The Hitchhiker's Guide
请问大家 Python await(asyncio)的后面只能接一个协程吗,例如 await asyncio.sleep(5)不能是 await lambda x:x+1
linhanqiu · Oct 18, 2017 · 2808 viewsThis topic created in 3173 days ago, the information mentioned may be changed or developed.
6 replies • 2017-10-19 07:36:42 +08:00
 |
1
ipwx Oct 18, 2017
你可以定义一个 async def consumer(q)
|
 |
2
linhanqiu OP @ipwx 多谢,我也刚刚想到,并且测试好了,可以这么用,不知道大神有没有用过 asyncio 加上 mulitprocessing 共用的情况
|
 |
3
1314258 Oct 18, 2017
不能 await lambda x:x+1
lambda 不能 awaitable。 |
Select Language