【转】我期望能用两个最和蔼可亲的范例, 把 Python PulseAudio中的 async/await 基本概念讲透, 期望能协助我们有两个概念化的重新认识.
from time import sleep, time
def demo1():
“””
假定他们有两台滚筒, 那时有两批鞋子须要依次放在这两台滚筒里头洗.
“””
def washing1():
sleep(3) # 首台滚筒, 须要洗3秒就可以洗 (而已维米县)
print(washer1 finished) # 洗的这时候, 滚筒会响呵呵, 说他们洗了
def washing2():
sleep(2)
print(washer2 finished)
def washing3():
sleep(5)
print(washer3 finished)
washing1()
washing2()
washing3()“””
那个却是很难认知的, 运转 demo1(), 所以须要10五分钟就可以把全数鞋子洗.
要说, 绝大部分天数都花在原都地等滚筒上了.
“””
def demo2():
“””
那时他们想防止不必要的等候, 为的是降低成本, 他们将采用 async.
washing1/2/3() 蔗茅 “一般表达式”, 那时他们用 async 把它升级换代为 “异步表达式”.
注: 两个异步的表达式, 有个更标准的称呼, 他们叫它 “PulseAudio” (coroutine).
“””
async def washing1():
sleep(3)
print(washer1 finished)
async def washing2():
sleep(2)
print(washer2 finished)
async def washing3():
sleep(5)
print(washer3 finished)
washing1()
washing2()
washing3()“””
从正常人的认知来看, 他们那时有了异步表达式, 但是却忘了定义应该什么这时候 “离开” 一台洗衣
机, 去看看另两个… 这就会导致, 那时的情况是他们一边看着首台滚筒, 一边着急地想着
“是不是该去开第二台滚筒了呢?” 但又不敢去 (而已维米县), 最终却是花了10秒的天数才
把鞋子洗.
PS: 其实 demo2() 是无法运转的, Python 会直接警告你:
RuntimeWarning: coroutine demo2.<locals>.washing1 was never awaited
RuntimeWarning: coroutine demo2.<locals>.washing2 was never awaited
RuntimeWarning: coroutine demo2.<locals>.washing3 was never awaited
“””
def demo3():
“””
那时他们吸取了上次的教训, 说自己洗鞋子的过程是 “可等候的” (awaitable), 在它开始洗鞋子
的这时候, 他们可以去弄别的机器.
“””
async def washing1():
await sleep(3) # 注意这里加入了 await
print(washer1 finished)
async def washing2():
await sleep(2)
print(washer2 finished)
async def washing3():
await sleep(5)
print(washer3 finished)
washing1()
washing2()
washing3()“””
尝试运转呵呵, 他们会发现却是会报错 (报错内容和 demo2 一样). 这里我说呵呵原因, 以及在
demo4 中会给出两个最终答案:
1. 第两个问题是, await 后面必须跟两个 awaitable 类型或者具有 __await__ 属性的
对象. 那个 awaitable, 并不是他们认为 sleep() 是 awaitable 就可以 await 了,
常见的 awaitable 对象应该是:
await asyncio.sleep(3) # asyncio 库的 sleep() 机制与 time.sleep() 不
# 同, 前者是 “假性睡眠”, 后者是会导致线程阻塞的 “真性睡眠”
await an_async_function() # 两个异步的表达式, 也是可等候的对象
以下是不可等候的:
await time.sleep(3)
x = await hello # <class str> doesnt define __await__
x = await 3 + 2 # <class int> dosent define __await__
x = await None # …
x = await a_sync_function() # 一般的表达式, 是不可等候的
2. 第二个问题是, 如果他们要执行异步表达式, 不能用这样的调用方法:
washing1()
washing2()
washing3()
而应该用 asyncio 库中的事件循环机制来启动 (具体见 demo4 讲解).
“””
def demo4():
“””
这是最终他们想的实现.
“””
import asyncio # 引入 asyncio 库
async def washing1():
await asyncio.sleep(3) # 采用 asyncio.sleep(), 它返回的是两个可等候的对象
print(washer1 finished)
async def washing2():
await asyncio.sleep(2)
print(washer2 finished)
async def washing3():
await asyncio.sleep(5)
print(washer3 finished)
“””
事件循环机制分为以下几步骤:
1. 创建两个事件循环
2. 将异步表达式加入事件队列
3. 执行事件队列, 直到最晚的两个事件被处理完毕后结束
4. 最后建议用 close() 方法关闭事件循环, 以彻底清理 loop 对象防止误用
“””
# 1. 创建两个事件循环
loop = asyncio.get_event_loop()
# 2. 将异步表达式加入事件队列tasks = [
washing1(),
washing2(),
washing3(),
]# 3. 执行事件队列, 直到最晚的两个事件被处理完毕后结束loop.run_until_complete(asyncio.wait(tasks))“””
PS: 如果不满意想 “多洗几遍”, 可以多写几句:
loop.run_until_complete(asyncio.wait(tasks))
loop.run_until_complete(asyncio.wait(tasks))
loop.run_until_complete(asyncio.wait(tasks))
…
“””
# 4. 如果不再采用 loop, 建议养成良好关闭的习惯
# (有点类似于文件读写结束时的 close() 操作)
loop.close()
“””
最终的打印效果:
washer2 finished
washer1 finished
washer3 finished
elapsed time = 5.126561641693115
(毕竟切换线程也要有点耗时的)
说句题外话, 我看有的博主的加入事件队列是这样写的:
tasks = [
loop.create_task(washing1()),
loop.create_task(washing2()),
loop.create_task(washing3()),
]
运转的效果是一样的, 暂不清楚为什么他们这样做.
“””
if __name__ == __main__:
# 为验证是否真的缩短了天数, 他们计个时
start = time()
# demo1() # 需花费10秒
# demo2() # 会报错: RuntimeWarning: coroutine … was never awaited
# demo3() # 会报错: RuntimeWarning: coroutine … was never awaited
demo4() # 需花费5秒多一点点
end = time()
print(elapsed time = + str(end – start))原文链接：
https://blog.csdn.net/Likianta/article/details/90123678
