在python里使用await關(guān)鍵字來(lái)等另外一個(gè)協(xié)程的實(shí)例
一個(gè)協(xié)程里可以啟動(dòng)另外一個(gè)協(xié)程,并等待它完成返回結(jié)果,采用await關(guān)鍵字,
例子如下:
import asyncio async def outer(): print(’in outer’) print(’waiting for result1’) result1 = await phase1() print(’waiting for result2’) result2 = await phase2(result1) return (result1, result2) async def phase1(): print(’in phase1’) return ’result1’ async def phase2(arg): print(’in phase2’) return ’result2 derived from {}’.format(arg) event_loop = asyncio.get_event_loop()try: return_value = event_loop.run_until_complete(outer()) print(’return value: {!r}’.format(return_value))finally: event_loop.close()輸出結(jié)果如下:in outerwaiting for result1in phase1waiting for result2in phase2return value: (’result1’, ’result2 derived from result1’)
await關(guān)鍵字添加了一個(gè)新的協(xié)程到循環(huán)里,而不需要明確地添加協(xié)程到這個(gè)事件循環(huán)里。
補(bǔ)充知識(shí):python里使用Condition對(duì)象來(lái)喚醒指定數(shù)量的協(xié)程
在asyncio庫(kù)里,定義Condition對(duì)象,它的行為與事件Event有點(diǎn)像,區(qū)別是事件是通知所有對(duì)象,Condition對(duì)象可以指定一定數(shù)量的協(xié)程被通知,它是通過(guò)函數(shù)notify()來(lái)實(shí)現(xiàn)的,如果參數(shù)里放2,就是通知兩個(gè)協(xié)程,例子如下:
import asyncio async def consumer(condition, n): with await condition: print(’consumer {} is waiting’.format(n)) await condition.wait() print(’consumer {} triggered’.format(n)) print(’ending consumer {}’.format(n)) async def manipulate_condition(condition): print(’starting manipulate_condition’) # pause to let consumers start await asyncio.sleep(0.1) for i in range(1, 3): with await condition: print(’notifying {} consumers’.format(i)) condition.notify(n=i) await asyncio.sleep(0.1) with await condition: print(’notifying remaining consumers’) condition.notify_all() print(’ending manipulate_condition’) async def main(loop): # Create a condition condition = asyncio.Condition() # Set up tasks watching the condition consumers = [ consumer(condition, i) for i in range(5) ] # Schedule a task to manipulate the condition variable loop.create_task(manipulate_condition(condition)) # Wait for the consumers to be done await asyncio.wait(consumers) event_loop = asyncio.get_event_loop()try: result = event_loop.run_until_complete(main(event_loop))finally: event_loop.close()
結(jié)果輸出如下:
starting manipulate_conditionconsumer 2 is waitingconsumer 3 is waitingconsumer 4 is waitingconsumer 1 is waitingconsumer 0 is waitingnotifying 1 consumersconsumer 2 triggeredending consumer 2notifying 2 consumersconsumer 3 triggeredending consumer 3consumer 4 triggeredending consumer 4notifying remaining consumersending manipulate_conditionconsumer 1 triggeredending consumer 1consumer 0 triggeredending consumer 0
以上這篇在python里使用await關(guān)鍵字來(lái)等另外一個(gè)協(xié)程的實(shí)例就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
