asyncio.create_task(協(xié)程對(duì)象)

async def func():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return "test"
async def main():
    print("main start")
    # python 3.7及以上版本的寫法
    # task1 = asyncio.create_task(func())
    # task2 = asyncio.create_task(func())
    # python3.7以前的寫法
    task1 = asyncio.ensure_future(func())
    task2 = asyncio.ensure_future(func())
    print("main end")
    ret1 = await task1
    ret2 = await task2
    print(ret1, ret2)
# python3.7以后的寫法
# asyncio.run(main())
# python3.7以前的寫法
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
"""
在創(chuàng)建task的時(shí)候，就將創(chuàng)建好的task添加到了時(shí)間循環(huán)當(dāng)中，所以說必須得有時(shí)間循環(huán)，才可以創(chuàng)建task，否則會(huì)報(bào)錯(cuò)
"""

async def func1():
    print(1111)
    await asyncio.sleep(2)
    print(2222)
    return "test"
async def main1():
    print("main start")
    tasks = [
        asyncio.ensure_future(func1()),
        asyncio.ensure_future(func1())
    ]
    print("main end")
    # 執(zhí)行成功后結(jié)果在done中， wait中可以加第二個(gè)參數(shù)timeout，如果在超時(shí)時(shí)間內(nèi)沒有完成，那么pending就是未執(zhí)行完的東西
    done, pending = await asyncio.wait(tasks, timeout=1)
    print(done)
    #print(pending)
# python3.7以前的寫法
loop = asyncio.get_event_loop()
loop.run_until_complete(main1())

"""
方式二的簡化版，就是tasks中不直接添加task，而是先將協(xié)程對(duì)象加入到list中，在最后運(yùn)行中添加
"""
async def func2():
    print(1111)
    await asyncio.sleep(2)
    print(2222)
    return "test"
tasks = [
    func2(),
    func2()
]
# python3.7以前的寫法
loop = asyncio.get_event_loop()
done, pending = loop.run_until_complete(asyncio.wait(tasks))
print(done)
print(pending)