python async 使用,介绍

geteshi
2022-07-18 / 0 评论 / 36 阅读 / 正在检测是否收录...

程序在执行 IO 密集型任务的时候,程序会因为等待 IO 而阻塞,而协程作为一种用户态的轻量级线程,可以帮我们解决这个问题

说人话:说白了就是,当协程遇到io操作而阻塞时,立即切换到别的任务,如果操作完成则进行回调返回执行结果,提高了效率,同时这样也可以充分利用 CPU 和其他资源,这就是异步协程的优势,并且协程本质上是个单进程,相对于多进程来说,无需进程间上下文切换的开销,无需原子操作锁定及同步的开销,编程模型也非常简单。

async/await 是python3的新特性,可以进行协程运行。个人将他理解成多线程。实现代码如下

import time
import asyncio

async def SleepTime(ts):
    if ts == 3:
        await asyncio.sleep(10) #当ts等于3的时候,让挂起的时间为10s,其他的按正常挂起,验证协程时间。
    else:
        await asyncio.sleep(ts)

async def main(loop):
    tasks = []
    for i in range(6):
        print("time begin %s"%i)
        tasks.append(loop.create_task(SleepTime(i))) #相当于开启了一个线程
        print("sleep time end %s"%i)
        print("*********************")
    await asyncio.wait(tasks) #等待所有的任务完成。

if __name__ == "__main__":
    # main()
    print("begin test")
    tb = time.time()
    print(tb) #记录当前时间
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main(loop))
    loop.close()
    print(time.time()-tb) #记录结束时间
    print("end")` 

运行结果如下,没有用到协程的结果,会依次执行,总耗时会大于10秒。

begin test
1602423299.3981705
time begin 0
sleep time end 0
*********************
time begin 1
sleep time end 1
*********************
time begin 2
sleep time end 2
*********************
time begin 3
sleep time end 3
*********************
time begin 4
sleep time end 4
*********************
time begin 5
sleep time end 5
*********************
10.005681276321411
end
[Finished in 10.2s]
0

评论 (0)

取消