在python里使用await关键字来等另外一个协程的实例
2020-05-05 07:07
1141 查看
一个协程里可以启动另外一个协程,并等待它完成返回结果,采用await关键字,
例子如下:
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() 输出结果如下: in outer waiting for result1 in phase1 waiting for result2 in phase2 return value: ('result1', 'result2 derived from result1')
await关键字添加了一个新的协程到循环里,而不需要明确地添加协程到这个事件循环里。
补充知识:python里使用Condition对象来唤醒指定数量的协程
在asyncio库里,定义Condition对象,它的行为与事件Event有点像,区别是事件是通知所有对象,Condition对象可以指定一定数量的协程被通知,它是通过函数notify()来实现的,如果参数里放2,就是通知两个协程,例子如下:
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()
结果输出如下:
starting manipulate_condition consumer 2 is waiting consumer 3 is waiting consumer 4 is waiting consumer 1 is waiting consumer 0 is waiting notifying 1 consumers consumer 2 triggered ending consumer 2 notifying 2 consumers consumer 3 triggered ending consumer 3 consumer 4 triggered ending consumer 4 notifying remaining consumers ending manipulate_condition consumer 1 triggered ending consumer 1 consumer 0 triggered ending consumer 0
以上这篇在python里使用await关键字来等另外一个协程的实例就是小编分享给大家的全部内容了,希望能给大家一个参考
您可能感兴趣的文章:
相关文章推荐
- python里使用await关键字来等另外一个协程
- Python 实现的一个使用接口的实例
- 深入理解Python中协程的应用机制: 使用纯Python来实现一个操作系统吧!!
- 以一个投票程序的实例来讲解Python的Django框架使用
- Python3基础 __str__ print一个类的实例对象的时候 使用的魔法方法
- python里使用difflib库的比较功能把一个序列变成另外一个序列
- 深入理解Python中协程的应用机制: 使用纯Python来实现一个操作系统吧!!
- 使用Promise和async-await实现的一个异步遍历+同步执行任务的实例
- c#-无法使用一个实例变量来初始化另外一个实例变量
- python很重要Python 是一个高层次的结合了解释性、编译性、互动性和面向对象的脚本语言。 Python 的设计具有很强的可读性,相比其他语言经常使用英文关键字,其他语言的一些标点符号,它具有比
- 用python写的一个使用关键字定向生成密码字典的脚本
- 深入理解Python中协程的应用机制: 使用纯Python来实现一个操作系统吧!!
- Python中使用wxPython开发的一个简易笔记本程序实例
- 使用事件处理创建一个简单的绘图实例程序 python
- tcl/tk实例详解——修改目录下所有文件(使用一个字符串代替另外一个)
- 深入理解Python中协程的应用机制: 使用纯Python来实现一个操作系统吧!!
- Python中使用wxPython开发的一个简易笔记本程序实例
- python使用线程封装的一个简单定时器类实例
- 在python里协程使用同步锁Lock的实例