快捷導(dǎo)航

Python 中由 yield 實(shí)現(xiàn)異步操作

更新時間：2020年05月04日 11:11:40 作者：silverze

這篇文章主要介紹了Python 中由 yield 實(shí)現(xiàn)異步操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

yield在python中初學(xué)時，覺得比較難理解。yield的作用：

①返回一個值、②接收調(diào)用者的參數(shù)

分析下面的代碼：

#!/usr/bin/env python3
# -*- coding:utf-8 -*-

def consumer():
  r = ''
  while True:
    n = yield r
    print("[Consumer] n = %d" %n)
    if not n:
      return
    print("[Consumer] consuming %s..." %n)
    r = '200 OK'

def produce(c):
  c.send(None)
  h = 0
  while h < 5:
    h = h + 1
    print("[Producer] producing %d..." %h)
    s = c.send(h)
    print("[Producer] consumer return: %s" %s)
  c.close()

c = consumer() #創(chuàng)建一個生成器
produce(c) #在該函數(shù)中，調(diào)用生成器的send()方法

結(jié)合程序運(yùn)行過程，可分析出：

第一步：

在produce(c)函數(shù)中，調(diào)用了c.send(None)啟動了生成器，遇到y(tǒng)ield暫停；接著執(zhí)行produce()中接下來的代碼，從運(yùn)行結(jié)果看，確實(shí)打印出了[Produce] producing 1 … 當(dāng)程序運(yùn)行至c.send(h)時，調(diào)用生成器并且通過yield傳遞了參數(shù)(h = 1)進(jìn)入consumer()函數(shù)執(zhí)行。

第二步：

yield傳遞參數(shù)（h=1）給consumer()函數(shù)中的n,并接著上一次暫停處往下繼續(xù)執(zhí)行，打印出[Consumer] n = 1，[Consumer] consuming 1… ；在consumer()函數(shù)中此時 r 被賦值為'200 OK',接著循環(huán)遇到y(tǒng)ield， consumer()函數(shù)又暫停并且返回變量 r 的值，此時程序又進(jìn)入produce(c)函數(shù)中接著執(zhí)行。

第三步：

produce(c)函數(shù)接著第一步中c.send(h)處，繼續(xù)往下執(zhí)行打印出[Producer] consumer return: 200 OK，并進(jìn)行循環(huán)，打印[Producer] producing 2… 后，又調(diào)用c.send(h) 。。。如此循環(huán)回到第一步！

補(bǔ)充知識：python asyncio模型事件循環(huán)

異步建立在事件循環(huán)上.

簡單來說事件循環(huán):

1.把要執(zhí)行的函數(shù)放入隊(duì)列

2.取出函數(shù),執(zhí)行

3.看看還要不要繼續(xù)放入此函數(shù)

4.繼續(xù)第一步

一個簡單的例子說明:

"""
  1.yield 掛起當(dāng)前函數(shù).
  2.使用調(diào)度器循環(huán)
  3.使用next喚醒此函數(shù)繼續(xù)執(zhí)行
"""
def f1():
  for i in range(3):
    print('f1 %d'%i)
    yield
def f2():
  for i in range(5):
    print('f2 %d' %i)
    yield
def f3():
  for i in range(10):
    print('f3 %d'%i)
    yield
#模擬一個調(diào)度器
task_q = collections.deque((f1(),f2(),f3()))
#讓調(diào)度器調(diào)度這些生成器們
while task_q:
  task = task_q.popleft() #彈出首個生成器
  try:
    next(task)     #執(zhí)行,如果沒有異常證明此生成器還沒執(zhí)行完成,可以繼續(xù)放入隊(duì)列中
    task_q.append(task) #執(zhí)行完成后,把任務(wù)繼續(xù)添加到隊(duì)列中.
    time.sleep(0.5)
  except StopIteration as ex:
    pass

以上這篇Python 中由 yield 實(shí)現(xiàn)異步操作就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: