# 1. greenlet實(shí)現(xiàn)協(xié)程
from greenlet import greenlet
def func1():
    print(1)    #第二步：輸出1
    gr2.swith()     #第三步：切換到func2函數(shù)
    print(2)    #第六步：輸出2
def func2():
    print(3)    #第四步：輸出3
    gr1.switch()    #第五步：切換到func1函數(shù)
    print(4)    #第七步：輸出4
gr1 = greenlet(func1())
gr2 = greenlet(func2())
gr1.switch()    #第一步：執(zhí)行func1函數(shù)

# 2. yield關(guān)鍵字 實(shí)現(xiàn)協(xié)程
def func1():    #如果一個(gè)函數(shù)中，存在yield關(guān)鍵字，則認(rèn)為是一個(gè)生成器，則執(zhí)行該函數(shù)，就生成一個(gè)生成器
    yield 1     #第二步：輸出1
    yield from func2()  #第三步：表示跳到func2函數(shù)中
    yield 2     #第六步：輸出2
def func2():
    yield 3     #第四步：輸出3
    yield 4     #第五步：輸出4
f1 = func1()
for item in f1:
    print(item) #第一步：執(zhí)行func1函數(shù)

# 3. asyncio 實(shí)現(xiàn)協(xié)程【無(wú)需安裝，但要求python需3.4及以上版本】
# 注意：遇到IO阻塞自動(dòng)切換
import asyncio
@asyncio.coroutine
def func1():    #func1位普通函數(shù)，添加了asynic.coroutine裝飾器后，則認(rèn)為該函數(shù)為協(xié)程函數(shù)
    print(1)
    yield  from asyncio.sleep(2)  # 遇到IO耗時(shí)操作，自動(dòng)切換到tasks中的其他任務(wù)
    print(2)
@asyncio.coroutine
def func2():
    print(3)
    yield  from asyncio.sleep(2)    # 遇到IO耗時(shí)操作，自動(dòng)切換到tasks中的其他任務(wù)
    print(4)
#協(xié)程函數(shù)的執(zhí)行， 則無(wú)法使用func1()方法進(jìn)行執(zhí)行，需要以下的方法進(jìn)行執(zhí)行
# loop = asyncio.get_event_loop()
# loop.run_until_complete(函數(shù)名稱)  #使用以上代碼，執(zhí)行函數(shù)的協(xié)程操作 如：loop.run_until_complete(func())
#對(duì)func1和func2函數(shù)進(jìn)行封裝， 然后使用下面的4句代碼，在pyhton內(nèi)部，同時(shí)會(huì)執(zhí)行這兩個(gè)協(xié)程函數(shù)，線程會(huì)隨機(jī)執(zhí)行所有函數(shù)中的一個(gè)
tasks = [
    asyncio.ensure_future(func1()),
    asyncio.ensure_future(func2())
]
# 線程函數(shù)會(huì)隨機(jī)執(zhí)行func1和func2協(xié)程函數(shù)
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))

# 4. async & await關(guān)鍵字【推薦】  在python3.5及以上
import asyncio
async def func1():    #func1位普通函數(shù)，添加了asynic.coroutine裝飾器后，則認(rèn)為該函數(shù)為協(xié)程函數(shù)
        print(1)
        await asyncio.sleep(2)  # 遇到IO耗時(shí)操作，自動(dòng)切換到tasks中的其他任務(wù)
        print(2)
@asyncio.coroutine
async def func2():
        print(3)
        await asyncio.sleep(2)    # 遇到IO耗時(shí)操作，自動(dòng)切換到tasks中的其他任務(wù)
        print(4)
#對(duì)func1和func2函數(shù)進(jìn)行封裝， 然后使用下面的4句代碼，在pyhton內(nèi)部，同時(shí)會(huì)執(zhí)行這兩個(gè)協(xié)程函數(shù)，線程會(huì)隨機(jī)執(zhí)行所有函數(shù)中的一個(gè)
tasks = [
    asyncio.ensure_future(func1()),
    asyncio.ensure_future(func2())
]
# 線程函數(shù)會(huì)隨機(jī)執(zhí)行func1和func2協(xié)程函數(shù)
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))