#這里的任務(wù)是有狀態(tài)的，比如這個(gè)任務(wù)已經(jīng)完成或者正在執(zhí)行或者正在IO等待
任務(wù)列表 = [ 任務(wù)1, 任務(wù)2, 任務(wù)3,... ]
while True:
    可執(zhí)行的任務(wù)列表，已完成的任務(wù)列表 = 去任務(wù)列表中檢查所有的任務(wù)，將'可執(zhí)行'和'已完成'的任務(wù)返回
    for 就緒任務(wù) in 可執(zhí)行的任務(wù)列表:
        執(zhí)行已就緒的任務(wù)
    for 已完成的任務(wù) in 已完成的任務(wù)列表:
        在任務(wù)列表中移除 已完成的任務(wù)
    如果 任務(wù)列表 中的任務(wù)都已完成，則終止循環(huán)

#在編寫程序時(shí)候可以通過(guò)如下代碼來(lái)獲取和創(chuàng)建事件循環(huán)。
import asyncio
loop = asyncio.get_event_loop()
#將任務(wù)放到任務(wù)列表，讓事件循環(huán)去檢測(cè)任務(wù)的狀態(tài)(是否可運(yùn)行，是否IO)
loop.loop.run_until_complete(任務(wù))

# 定義一個(gè)協(xié)程函數(shù)
async def func():
    pass
# 調(diào)用協(xié)程函數(shù)，返回一個(gè)協(xié)程對(duì)象(內(nèi)部代碼不會(huì)執(zhí)行)
result = func()

import asyncio
async def func():
    print("協(xié)程內(nèi)部代碼")
# 調(diào)用協(xié)程函數(shù)，返回一個(gè)協(xié)程對(duì)象。
result = func()
# 方式一
# loop = asyncio.get_event_loop() # 創(chuàng)建一個(gè)事件循環(huán)
# loop.run_until_complete(result) # 將協(xié)程當(dāng)做任務(wù)提交到事件循環(huán)的任務(wù)列表中，協(xié)程執(zhí)行完成之后終止。
# 方式二
# 本質(zhì)上方式一是一樣的，內(nèi)部先 創(chuàng)建事件循環(huán) 然后執(zhí)行 run_until_complete，一個(gè)簡(jiǎn)便的寫法。
# asyncio.run 函數(shù)在 Python 3.7 中加入 asyncio 模塊，
asyncio.run(result)

import asyncio
async def func():
    print("執(zhí)行協(xié)程函數(shù)內(nèi)部代碼")
    # 遇到IO操作掛起當(dāng)前協(xié)程（任務(wù)），等IO操作完成之后再繼續(xù)往下執(zhí)行。
    # 當(dāng)前協(xié)程掛起時(shí)，事件循環(huán)可以去執(zhí)行其他協(xié)程（任務(wù)）。
	#response是IO耗時(shí)結(jié)束后拿到的結(jié)果
    response = await asyncio.sleep(2)
    print("IO請(qǐng)求結(jié)束，結(jié)果為：", response)
result = func()
asyncio.run(result)

import asyncio
async def others():
    print("start")
    await asyncio.sleep(2)
    print('end')
    return '返回值'
async def func():
    print("執(zhí)行協(xié)程函數(shù)內(nèi)部代碼")
    # 遇到IO操作掛起當(dāng)前協(xié)程（任務(wù)），等IO操作完成之后再繼續(xù)往下執(zhí)行。當(dāng)前協(xié)程掛起時(shí)，事件循環(huán)可以去執(zhí)行其他協(xié)程（任務(wù)）。
    response = await others()
    print("IO請(qǐng)求結(jié)束，結(jié)果為：", response)
asyncio.run( func() )

import asyncio
async def others():
    print("start")
    await asyncio.sleep(2)
    print('end')
    return '返回值'
async def func():
    print("執(zhí)行協(xié)程函數(shù)內(nèi)部代碼")
    # 遇到IO操作掛起當(dāng)前協(xié)程（任務(wù)），等IO操作完成之后再繼續(xù)往下執(zhí)行。當(dāng)前協(xié)程掛起時(shí)，事件循環(huán)可以去執(zhí)行其他協(xié)程（任務(wù)）。
    #await等待有返回值才會(huì)向下執(zhí)行
    response1 = await others()
    print("IO請(qǐng)求結(jié)束，結(jié)果為：", response1)
    response2 = await others()
    print("IO請(qǐng)求結(jié)束，結(jié)果為：", response2)
asyncio.run( func() )

import asyncio
async def func():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return "返回值"
async def main():
    print("main開始")
    # 創(chuàng)建協(xié)程，將協(xié)程封裝到一個(gè)Task對(duì)象中并立即添加到事件循環(huán)的任務(wù)列表中，等待事件循環(huán)去執(zhí)行（默認(rèn)是就緒狀態(tài)）。
    task1 = asyncio.create_task(func())
    # 創(chuàng)建協(xié)程，將協(xié)程封裝到一個(gè)Task對(duì)象中并立即添加到事件循環(huán)的任務(wù)列表中，等待事件循環(huán)去執(zhí)行（默認(rèn)是就緒狀態(tài)）。
    task2 = asyncio.create_task(func())
    print("main結(jié)束")
    # 當(dāng)執(zhí)行某協(xié)程遇到IO操作時(shí)，會(huì)自動(dòng)化切換執(zhí)行其他任務(wù)。
    # 此處的await是等待相對(duì)應(yīng)的協(xié)程全都執(zhí)行完畢并獲取結(jié)果
    ret1 = await task1
    ret2 = await task2
    print(ret1, ret2)
asyncio.run(main())

import asyncio
async def func():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return "返回值"
async def main():
    print("main開始")
    # 創(chuàng)建協(xié)程，將協(xié)程封裝到Task對(duì)象中并添加到事件循環(huán)的任務(wù)列表中，等待事件循環(huán)去執(zhí)行（默認(rèn)是就緒狀態(tài)）。
    # 在調(diào)用
    task_list = [
        asyncio.create_task(func(), name="n1"),
        asyncio.create_task(func(), name="n2")
    ]
    print("main結(jié)束")
    # 當(dāng)執(zhí)行某協(xié)程遇到IO操作時(shí)，會(huì)自動(dòng)化切換執(zhí)行其他任務(wù)。
    # 此處的await是等待所有協(xié)程執(zhí)行完畢，并將所有協(xié)程的返回值保存到done
    # 如果設(shè)置了timeout值，則意味著此處最多等待的秒，完成的協(xié)程返回值寫入到done中，未完成則寫到pending中(比如下面的Timeout=1,要下載的圖片是兩秒，設(shè)為1秒就會(huì)執(zhí)行失敗,done內(nèi)為空，而pending中就是執(zhí)行失敗的)。
    done, pending = await asyncio.wait(task_list, timeout=None)
    print(done, pending)
asyncio.run(main())

執(zhí)行結(jié)果：
main開始
main結(jié)束
1
1
2
2
{
   <Task finished name='n1' coro=<func() done, defined at C:/Users/xuan.li/Desktop/unidevopss/py3x64/ibuildmaster/apps/PROD/tests.py:513> result='返回值'>,
   <Task finished name='n2' coro=<func() done, defined at C:/Users/xuan.li/Desktop/unidevopss/py3x64/ibuildmaster/apps/PROD/tests.py:513> result='返回值'>
}
 set()

import asyncio
async def func():
    print("執(zhí)行協(xié)程函數(shù)內(nèi)部代碼")
    # 遇到IO操作掛起當(dāng)前協(xié)程（任務(wù)），等IO操作完成之后再繼續(xù)往下執(zhí)行。當(dāng)前協(xié)程掛起時(shí)，事件循環(huán)可以去執(zhí)行其他協(xié)程（任務(wù)）。
    response = await asyncio.sleep(2)
    print("IO請(qǐng)求結(jié)束，結(jié)果為：", response)
coroutine_list = [func(), func()]
# 錯(cuò)誤：coroutine_list = [ asyncio.create_task(func()), asyncio.create_task(func()) ]  
# 此處不能直接 asyncio.create_task，因?yàn)閷ask立即加入到事件循環(huán)的任務(wù)列表，
# 但此時(shí)事件循環(huán)還未創(chuàng)建，所以會(huì)報(bào)錯(cuò)。
# 使用asyncio.wait將列表封裝為一個(gè)協(xié)程，并調(diào)用asyncio.run實(shí)現(xiàn)執(zhí)行兩個(gè)協(xié)程
# asyncio.wait內(nèi)部會(huì)對(duì)列表中的每個(gè)協(xié)程執(zhí)行ensure_future，封裝為Task對(duì)象。
done,pending = asyncio.run( asyncio.wait(coroutine_list) )