import time
import greenlet
 
 
def func1():
  print("func11")
  gr2.switch()
  time.sleep(1)
  print("func22")
  gr2.switch()
 
 
def func2():
  print("func33")
  gr1.switch()
  time.sleep(1)
  print("func44")
 
 
start = time.time()
gr1 = greenlet.greenlet(func1)
gr2 = greenlet.greenlet(func2)
gr1.switch()
end = time.time()
print(end - start)

def func1():
  yield 1
  yield from func2()
  yield 3
 
 
def func2():
  yield 2
  yield 4
 
 
ff = func1()
for item in ff:
  print(item)

from greenlet import greenlet
from time import sleep
def func1():
  print("協(xié)程1")
  sleep(2)
  g2.switch()
  print("協(xié)程1恢復運行")
 
def func2():
  print("協(xié)程2")
  sleep(1)
  g3.switch()
def func3():
  print("協(xié)程3")
  sleep(1)
  g1.switch()
 
if __name__ == '__main__':
  # 使用greenlet來創(chuàng)建三個協(xié)程
  g1 = greenlet(func1)
  g2 = greenlet(func2)
  g3 = greenlet(func3)
  # print(g1)
  g1.switch() # 讓協(xié)程g1取搶占cpu資源

# 協(xié)程被創(chuàng)建出來以后默認是多個協(xié)程同步執(zhí)行
# 我們可以加入monkey補丁，把同步的協(xié)程轉成異步協(xié)程
from gevent import monkey # 注意：monkey的引入必須在其他模塊之前
 
monkey.patch_all() # 用monkey給整個協(xié)程隊列，添加一個非阻塞I/O的補丁，使得他們成為異步協(xié)程
import time
import requests
import gevent
 
headers = {
  'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/73.0.3683.86 Safari/537.36'}
 
 
def func(url, i):
  print("協(xié)程%d開啟！" % i)
  res = requests.get(url=url, headers=headers)
  html = res.text
  print("協(xié)程%d執(zhí)行結束，獲取到的響應體大小為：%d" % (i, len(html)))
 
 
if __name__ == '__main__':
  start = time.time()
  urls = [
    "https://www.baidu.com/",
    "https://www.qq.com/",
    "https://www.sina.com.cn",
    "https://www.ifeng.com/",
    "https://www.163.com/"
  ]
  # 創(chuàng)建5個協(xié)程分別對上面5個網(wǎng)站進行訪問
  g_list = []
  for i in range(len(urls)):
    g = gevent.spawn(func, urls[i], i)
    g_list.append(g)
    # func(urls[i], i)
  gevent.joinall(g_list)
  end = time.time()
  print(end - start)

import time
import asyncio
 
 
@asyncio.coroutine
def func1():
  print(1)
  yield from asyncio.sleep(1) # 遇到IO耗時操作，自動切換到tasks中的其它任務
  print(2)
 
 
@asyncio.coroutine
def func2():
  print(3)
  yield from asyncio.sleep(1) # 遇到IO耗時操作，自動切換到tasks中的其它任務
  print(4)
 
 
tasks = [
  asyncio.ensure_future(func1()),
  asyncio.ensure_future(func2())
]
 
start = time.time()
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))
end = time.time()
print(end - start)

import time
import asyncio
 
 
async def func1():
  print(1)
  await asyncio.sleep(1)
  print(2)
 
 
async def func2():
  print(3)
  await asyncio.sleep(1)
  print(4)
 
 
tasks = [
  asyncio.ensure_future(func1()),
  asyncio.ensure_future(func2())
]
 
start = time.time()
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))
end = time.time()
print(end - start)

# 偽代碼
任務列表 = [ 任務1, 任務2, 任務3,... ]
while True:
  可執(zhí)行的任務列表，已完成的任務列表 = 去任務列表中檢查所有的任務，將'可執(zhí)行'和'已完成'的任務返回
  for 就緒任務 in 已準備就緒的任務列表:
    執(zhí)行已就緒的任務
  for 已完成的任務 in 已完成的任務列表:
    在任務列表中移除 已完成的任務
  如果 任務列表 中的任務都已完成，則終止循環(huán)

# 定義一個協(xié)程函數(shù)
async def func():
  pass
# 調(diào)用協(xié)程函數(shù)，返回一個協(xié)程對象
result = func()

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

import asyncio
 
 
async def func1():
  print("start")
  await asyncio.sleep(1)
  print("end")
  return "func1執(zhí)行完畢"
 
 
async def func2():
  print("func2開始執(zhí)行")
  # await關鍵字后面可以跟可等待對象（協(xié)程對象、Future對象、Task對象)
  response = await func1()
  print(response)
  print("func2執(zhí)行完畢")
 
 
asyncio.run(func2())

import asyncio
 
 
async def func1():
  print("start")
  await asyncio.sleep(1)
  print("end")
  return "func1執(zhí)行完畢"
 
 
async def func2():
  print("func2開始執(zhí)行")
  # await關鍵字后面可以跟可等待對象（協(xié)程對象、Future對象、Task對象)
  response = await func1()
  print(response)
  response2 = await func1()
  print(response2)
  print("func2執(zhí)行完畢")
 
 
asyncio.run(func2())

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

import asyncio
 
 
async def func():
  print(1)
  await asyncio.sleep(1)
  print(2)
  return "func的返回值"
 
 
async def main():
  print(3)
  # 創(chuàng)建協(xié)程，將協(xié)程封裝到Task對象中并添加到事件循環(huán)的任務列表中，等待事件循環(huán)去執(zhí)行（默認是就緒狀態(tài)）。
  # 在調(diào)用
  task_list = [
    asyncio.create_task(func()),
    asyncio.create_task(func())
  ]
  # 當執(zhí)行某協(xié)程遇到IO操作時，會自動化切換執(zhí)行其他任務。
  # 此處的await是等待所有協(xié)程執(zhí)行完畢，并將所有協(xié)程的返回值保存到done
  # 如果設置了timeout值，則意味著此處最多等待的秒，完成的協(xié)程返回值寫入到done中，未完成則寫到pending中。
  done, pending = await asyncio.wait(task_list, timeout=None)
  print(done)
  print(pending)
 
 
asyncio.run(main())

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