import time
# 帶yield的函數(shù)并不是函數(shù)，而是一個(gè)生成器模板，返回一個(gè)生成器(可用于遍歷迭代)
def task_1():
  while True:
    time.sleep(0.1)
    yield # 阻塞，等待next迭代解阻塞
def task_2():
  while True:
    time.sleep(0.1)
    yield
def main():
  t1 = task_1() # 返回的t1是一個(gè)生成器。 此時(shí)并未執(zhí)行task_1中的代碼
  t2 = task_2()
  # 先讓t1運(yùn)行一會(huì)，當(dāng)t1中遇到y(tǒng)ield的時(shí)候，再返回到24行，然后
  # 執(zhí)行t2，當(dāng)它遇到y(tǒng)ield的時(shí)候，再次切換到t1中
  # 這樣t1/t2/t1/t2的交替運(yùn)行，最終實(shí)現(xiàn)了多任務(wù)....協(xié)程
  while True:
    next(t1) # 執(zhí)行task_1中的代碼，遇到y(tǒng)ield阻塞task_1。 等待下一次next激活。
    next(t2) # 實(shí)現(xiàn)task_1與task_2交替執(zhí)行，實(shí)現(xiàn)多任務(wù)...協(xié)程
if __name__ == "__main__":
  main()

from greenlet import greenlet # 需要安裝greenlet模塊 sudo pip3 install greenlet (python2.x使用pip) 
import time
def test1():
  while True:
    print("---A--")
    gr2.switch()  # 切換到gr2中的任務(wù)。
    time.sleep(0.5)
def test2():
  while True:
    print("---B--")
    gr1.switch()  # 切換到gr1中的任務(wù)。
    time.sleep(0.5)
gr1 = greenlet(test1) # greenlet 底層封裝了yield。
gr2 = greenlet(test2)
#切換到gr1中運(yùn)行
gr1.switch()

import gevent # 需要安裝gevent模塊 sudo pip3 install gevent (python2.x使用pip) 
import time
def f1(n):
  for i in range(n):
    print(gevent.getcurrent(), i)
    gevent.sleep(0.5)  # 為了提高協(xié)程效率,遇到阻塞類代碼,會(huì)自動(dòng)切換協(xié)程任務(wù)。
    # time.sleep(0.5)  # 阻塞類代碼必須使用gevent自己包裝的代碼，原生阻塞類代碼不會(huì)切換協(xié)程任務(wù)。 
              # 可以使用monkey.patch_all()將所有原生阻塞類代碼替換成gevent包裝的阻塞類代碼。 
def f2(n):
  for i in range(n):
    print(gevent.getcurrent(), i) # <Greenlet "Greenlet-0" at 0x7f4a09b34648: f1(5)> 0
    gevent.sleep(0.5)
    # time.sleep(0.5)
def f3(n):
  for i in range(n):
    print(gevent.getcurrent(), i)
    gevent.sleep(0.5)
    # time.sleep(0.5)
g1 = gevent.spawn(f1, 5) # gevent其實(shí)是對(duì)greenlet的封裝。
g2 = gevent.spawn(f2, 5) # 第一個(gè)參數(shù)f2表示協(xié)程執(zhí)行的具體任務(wù)(函數(shù))，第二個(gè)參數(shù)5表示要傳給f2的參數(shù)
g3 = gevent.spawn(f3, 5)
g1.join()  # 遇到阻塞類代碼,自動(dòng)切換協(xié)程任務(wù)。
g2.join()
g3.join()

import gevent # 需要安裝gevent模塊 sudo pip3 install gevent (python2.x使用pip)
import time
from gevent import monkey
# gevent打補(bǔ)丁
monkey.patch_all() # 將所有原生阻塞類代碼自動(dòng)替換成gevent包裝的阻塞類代碼。 
def f1(n):
  for i in range(n):
    print(gevent.getcurrent(), i)
    time.sleep(0.5) # 會(huì)自動(dòng)替換成 gevent.sleep(0.5)
def f2(n):
  for i in range(n):
    print(gevent.getcurrent(), i)
    time.sleep(0.5)
def f3(n):
  for i in range(n):
    print(gevent.getcurrent(), i)
    time.sleep(0.5)
# g1 = gevent.spawn(f1, 5)
# g2 = gevent.spawn(f2, 5)
# g3 = gevent.spawn(f3, 5)
# g1.join()
# g2.join()
# g3.join()
# 一種簡(jiǎn)便寫法
gevent.joinall([
    gevent.spawn(f1, 5),
    gevent.spawn(f2, 5),
    gevent.spawn(f3, 5)
])

import socket
import time
tcp_server_tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_server_tcp.bind(("", 7899))
tcp_server_tcp.listen(128)
tcp_server_tcp.setblocking(False) # 設(shè)置套接字為非堵塞的方式。 (接收數(shù)據(jù)時(shí)如果沒(méi)有接到數(shù)據(jù)(阻塞)那么就拋異常,否則正常接收數(shù)據(jù)。)
client_socket_list = list() # 用于保存與客戶端連接的套接字。
while True:
  # time.sleep(0.5)
  try:
    new_socket, new_addr = tcp_server_tcp.accept() # 用拋異常的方式代替阻塞。
  except Exception as ret:
    print("---沒(méi)有新的客戶端到來(lái)---")
  else:
    print("---只要沒(méi)有產(chǎn)生異常，那么也就意味著 來(lái)了一個(gè)新的客戶端----")
    new_socket.setblocking(False) # 設(shè)置套接字為非堵塞的方式。 (如果需要阻塞就直接拋異常代替阻塞)
    client_socket_list.append(new_socket)
  for client_socket in client_socket_list:
    try:
      recv_data = client_socket.recv(1024)  # 用拋異常的方式代替阻塞。
    except Exception as ret:
      print("----這個(gè)客戶端還沒(méi)有發(fā)送過(guò)來(lái)數(shù)據(jù)----")
    else:
      if recv_data:
        # 對(duì)方發(fā)送過(guò)來(lái)數(shù)據(jù)
        print("----客戶端發(fā)送過(guò)來(lái)了數(shù)據(jù)-----")
      else:
        # 對(duì)方調(diào)用close 導(dǎo)致了 recv返回
        client_socket.close()
        client_socket_list.remove(client_socket)
        print("---客戶端已經(jīng)關(guān)閉----")