asyncio
asyncio提供的@asyncio.coroutine可以把一个generator标记为coroutine类型，然后在coroutine内部用yield from调用另一个coroutine实现异步操作。
为了简化并更好地标识异步IO，从Python 3.5开始引入了新的语法async和await，可以让coroutine的代码更简洁易读。
请注意，async和await是针对coroutine的新语法，要使用新的语法，只需要做两步简单的替换：
- 把@asyncio.coroutine替换为async；
- 把yield from替换为await。
import asyncio
import threading
@asyncio.coroutine
def hello(): #new style: async def hello():
print("Hello world! %s"%threading.currentThread())
r = yield from asyncio.sleep(1) #new style: r = await asyncio.sleep(1)
print("Hello again! %s"%threading.currentThread())
loop = asyncio.get_event_loop()
task_list = [hello(),hello(),hello(),hello(),hello(),hello(),hello(),hello()]
#如果是单个任务
#loop.run_until_complete(hello())
loop.run_until_complete(asyncio.wait(task_list))
loop.close()
asyncio 使用常见招式
-
设置事件循环类型
- from asyncio.windows_events import ProactorEventLoop
适用于windows - asynco.SeletorEventLoop
适用于linux
asyncio.set_event_loop(asynco.SelectEventLoop())
- from asyncio.windows_events import ProactorEventLoop
-
设置任务
loop = asyncio.get_event_loop() #获取循环句柄
loop.run_until_complete(xxxx()) -
结束
loop.stop()
loop.close()
