Python 中由 yield 實現(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é)合程序運行過程,可分析出:
第一步:
在produce(c)函數(shù)中,調(diào)用了c.send(None)啟動了生成器,遇到y(tǒng)ield暫停;接著執(zhí)行produce()中接下來的代碼,從運行結(jié)果看,確實打印出了[Produce] producing 1 … 當(dāng)程序運行至c.send(h)時,調(diào)用生成器并且通過yield傳遞了參數(shù)(h = 1)進入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 的值,此時程序又進入produce(c)函數(shù)中接著執(zhí)行。
第三步:
produce(c)函數(shù)接著第一步中c.send(h)處,繼續(xù)往下執(zhí)行打印出[Producer] consumer return: 200 OK,并進行循環(huán),打印[Producer] producing 2… 后,又調(diào)用c.send(h) 。。。如此循環(huán)回到第一步!
補充知識:python asyncio模型 事件循環(huán)
異步建立在事件循環(huán)上.
簡單來說事件循環(huán):
1.把要執(zhí)行的函數(shù)放入隊列
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) yielddef f2(): for i in range(5): print(’f2 %d’ %i) yielddef 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ù)放入隊列中 task_q.append(task) #執(zhí)行完成后,把任務(wù)繼續(xù)添加到隊列中. time.sleep(0.5) except StopIteration as ex: pass
以上這篇Python 中由 yield 實現(xiàn)異步操作就是小編分享給大家的全部內(nèi)容了,希望能給大家一個參考,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. 解決Python 進程池Pool中一些坑2. 三個不常見的 HTML5 實用新特性簡介3. Python獲取抖音關(guān)注列表封號賬號的實現(xiàn)代碼4. Python使用jupyter notebook查看ipynb文件過程解析5. ajax請求添加自定義header參數(shù)代碼6. python利用os模塊編寫文件復(fù)制功能——copy()函數(shù)用法7. Python如何讀寫CSV文件8. php網(wǎng)絡(luò)安全中命令執(zhí)行漏洞的產(chǎn)生及本質(zhì)探究9. php測試程序運行速度和頁面執(zhí)行速度的代碼10. 無線標(biāo)記語言(WML)基礎(chǔ)之WMLScript 基礎(chǔ)第1/2頁
