cda

数字化人才认证

您的位置:首页 > 精彩阅读 > 学了协程之后,感觉有了无数个分身

学了协程之后,感觉有了无数个分身

2022-08-05

作者:小K

来源:麦叔编程

上次的关于进程、线程和协程的文章,很多粉丝留言表示想看协程的实际案例。

那么今天就来结合代码实际讲一个协程的实际应用。

在此之前,我希望大家能已经理解什么是串行、并行和并发的概念。如果你还不知道这三者的区别请前往Python三分钟第131篇复习学习。

普通函数

定义一个洗衣服函数,洗衣服过程时间为2秒。

睡眠

import timedef wash_clothes(): time.sleep(2) # 洗衣服def run(): for i in range(20):  wash_clothes() print(f"衣服洗好了!当前时间:{time.time()}") if __name__ == '__main__': run()

运行结果:

衣服洗好了!当前时间:1659618457.003896衣服洗好了!当前时间:1659618459.005437衣服洗好了!当前时间:1659618461.0056782衣服洗好了!当前时间:1659618463.010311衣服洗好了!当前时间:1659618465.013951衣服洗好了!当前时间:1659618467.018253衣服洗好了!当前时间:1659618469.022136衣服洗好了!当前时间:1659618471.022881衣服洗好了!当前时间:1659618473.023118衣服洗好了!当前时间:1659618475.027102衣服洗好了!当前时间:1659618477.030786衣服洗好了!当前时间:1659618479.032495衣服洗好了!当前时间:1659618481.037195衣服洗好了!当前时间:1659618483.040722衣服洗好了!当前时间:1659618485.041149衣服洗好了!当前时间:1659618487.046405衣服洗好了!当前时间:1659618489.0484421衣服洗好了!当前时间:1659618491.050224衣服洗好了!当前时间:1659618493.055479衣服洗好了!当前时间:1659618495.0585659

我们可以看出,函数间隔2秒多一点点输出一次时间。

协程函数

注意代码中注释

import timeimport asyncio# 异步函数定义需要在def前加async前缀async def wash_clothes():  # sleep也需要使用协程专用的模块支持,同步的库不能在异步中使用 asyncio.sleep(2) print(f"衣服洗好了!当前时间:{time.time()}")def run(): for i in range(20):    # 将协程函数注册到loop(循环事件)中 loop.run_until_complete(wash_clothes())# 创建一个协程loop(循环事件)中loop = asyncio.get_event_loop()if __name__ =='__main__': run()

运行结果:

衣服洗好了!当前时间:1659619085.0939178衣服洗好了!当前时间:1659619085.094379衣服洗好了!当前时间:1659619085.095523衣服洗好了!当前时间:1659619085.095926衣服洗好了!当前时间:1659619085.097046衣服洗好了!当前时间:1659619085.0985332衣服洗好了!当前时间:1659619085.099058衣服洗好了!当前时间:1659619085.099848衣服洗好了!当前时间:1659619085.101115衣服洗好了!当前时间:1659619085.101917衣服洗好了!当前时间:1659619085.1026182衣服洗好了!当前时间:1659619085.103351衣服洗好了!当前时间:1659619085.1034582衣服洗好了!当前时间:1659619085.1035311衣服洗好了!当前时间:1659619085.1042402衣服洗好了!当前时间:1659619085.1052392衣服洗好了!当前时间:1659619085.106337衣服洗好了!当前时间:1659619085.106577衣服洗好了!当前时间:1659619085.107519衣服洗好了!当前时间:1659619085.108191

从运行结果看出,20桶衣服几乎在同0.1秒内洗完了。

大致过程

  1. 定义协程函数;
  2. 创建协程循环事件;
  3. 将已定义的协程函数注册到协程循环事件中;
  4. 启动协程循环事件。

重点:协程函数内不能使用同步的函数或模块,否则将不会被异步运行。

上一篇Python我提了协程执行的过程就像,“一个人启动一台洗衣机后,马上去使用第二台洗衣机,再第三台...第四台...第十台”。

「当洗衣机启动后的状态就等于是挂起了」

然后协程马上去启动下一台洗衣机...一直到结束。

后记

在某种意义上说,处理IO密集型任务协程的速度会高于多线程,因为线程的创建和销毁需要消耗更多资源。

如果将这个大杀器用于网络爬虫,那不是速度要上天了?

是的,协程爬虫超猛。以前亲测比scrapy要快。

下期将从两个话题中选出一个:

  1. 什么是IO密集型任务和计算密集型任务?
  2. 协程爬虫
  3. 其他(写上内容)

完 谢谢观看

展开阅读全文
分享
收藏

OK