一個(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ì)象來喚醒指定數(shù)量的協(xié)程

在asyncio庫里，定義Condition對(duì)象，它的行為與事件Event有點(diǎn)像，區(qū)別是事件是通知所有對(duì)象，Condition對(duì)象可以指定一定數(shù)量的協(xié)程被通知，它是通過函數(shù)notify()來實(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)鍵字來等另外一個(gè)協(xié)程的實(shí)例就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持好吧啦網(wǎng)。