python 3.6+ 可以使用asyncio.ensure_future來創(chuàng)建一個協(xié)程任務
python3.7+可以使用asyncio.create_task...
官方文檔-協(xié)程介紹逆甜,以下測試代碼:
同時執(zhí)行4個任務冤狡,分別sleep1,3,5,3秒,并行時間5秒多一點说庭。
import a
import time
import asyncio
async def do_something_async():
time.sleep(1)
async def test_async(i):
await asyncio.sleep(i)
a.get_logger().info("something async %d", i)
await do_something_async()
a.get_logger().info("starting coroutines")
loop = asyncio.get_event_loop()
task1 = asyncio.ensure_future(test_async(1))
task2 = asyncio.ensure_future(test_async(3))
task3 = asyncio.ensure_future(test_async(5))
task4 = asyncio.ensure_future(test_async(3))
tasks = [
task1,
task2,
task3,
task4
]
loop.run_until_complete(asyncio.wait(tasks))