位置: IT常识 - 正文

Python中的协程是什么(python2.7 协程)

编辑:rootadmin

推荐整理分享Python中的协程是什么(python2.7 协程),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python协程gevent,python协程gevent,python协程用法,python协程在运行过程中有哪些状态,python协程在运行过程中有哪些状态,python 协程 yield,python协程在运行过程中有哪些状态,python协程在运行过程中有哪些状态,内容如对您有帮助,希望把文章链接给更多的朋友!

协程

在python GIL之下,同一时刻只能有一个线程在运行,那么对于CPU计算密集的程序来说,线程之间的切换开销就成了拖累,而以I/O为瓶颈的程序正是协程所擅长的:

Python中的协程经历了很长的一段发展历程。其大概经历了如下三个阶段:

1.最初的生成器变形yield/send;

2.引入@asyncio.coroutine和yield from;

3.在最近的Python3.5版本中引入async/await关键字。

(1)从yield说起

先看一段普通的计算斐波那契续列的代码

deffibs(n):res=[0]*nindex=0a=0b=1whileindex<n:res[index]=ba,b=b,a+bindex+=1returnresforfib_resinfibs(20):print(fib_res)

如果我们仅仅是需要拿到斐波那契序列的第n位,或者仅仅是希望依此产生斐波那契序列,那么上面这种传统方式就会比较耗费内存。

这时,yield就派上用场了。

deffib(n):index=0a=0b=1whileindex<n:yieldba,b=b,a+bindex+=1forfib_resinfib(20):print(fib_res)

当一个函数中包含yield语句时,python会自动将其识别为一个生成器。这时fib(20)并不会真正调用函数体,而是以函数体生成了一个生成器对象实例。

yield在这里可以保留fib函数的计算现场,暂停fib的计算并将b返回。而将fib放入for…in循环中时,每次循环都会调用next(fib(20)),唤醒生成器,执行到下一个yield语句处,直到抛出StopIteration异常。此异常会被for循环捕获,导致跳出循环。

(2) Send来了

从上面的程序中可以看到,目前只有数据从fib(20)中通过yield流向外面的for循环;如果可以向fib(20)发送数据,那不是就可以在Python中实现协程了嘛。

相关推荐:《Python视频教程》

于是,Python中的生成器有了send函数,yield表达式也拥有了返回值。

我们用这个特性,模拟一个慢速斐波那契数列的计算:

importtimeimportrandomdefstupid_fib(n):index=0a=0b=1whileindex<n:sleep_cnt=yieldbprint('letmethink{0}secs'.format(sleep_cnt))time.sleep(sleep_cnt)a,b=b,a+bindex+=1print('-'*10+'testyieldsend'+'-'*10)N=20sfib=stupid_fib(N)fib_res=next(sfib)whileTrue:print(fib_res)try:fib_res=sfib.send(random.uniform(0,0.5))exceptStopIteration:breakPython中的协程是什么(python2.7 协程)

python 进行并发编程

在Python 2的时代,高性能的网络编程主要是使用Twisted、Tornado和Gevent这三个库,但是它们的异步代码相互之间既不兼容也不能移植。

asyncio是Python 3.4版本引入的标准库,直接内置了对异步IO的支持。

asyncio的编程模型就是一个消息循环。我们从asyncio模块中直接获取一个EventLoop的引用,然后把需要执行的协程扔到EventLoop中执行,就实现了异步IO。

Python的在3.4中引入了协程的概念,可是这个还是以生成器对象为基础。

Python 3.5添加了async和await这两个关键字,分别用来替换asyncio.coroutine和yield from。

python3.5则确定了协程的语法。下面将简单介绍asyncio的使用。实现协程的不仅仅是asyncio,tornado和gevent都实现了类似的功能。

(1)协程定义

用asyncio实现Hello world代码如下:

importasyncio@asyncio.coroutinedefhello():print("Helloworld!")#异步调用asyncio.sleep(1):r=yieldfromasyncio.sleep(1)print("Helloagain!")#获取EventLoop:loop=asyncio.get_event_loop()#执行coroutineloop.run_until_complete(hello())loop.close()

@asyncio.coroutine把一个generator标记为coroutine类型,然后,我们就把这个coroutine扔到EventLoop中执行。 hello()会首先打印出Hello world!,然后,yield from语法可以让我们方便地调用另一个generator。由于asyncio.sleep()也是一个coroutine,所以线程不会等待asyncio.sleep(),而是直接中断并执行下一个消息循环。当asyncio.sleep()返回时,线程就可以从yield from拿到返回值(此处是None),然后接着执行下一行语句。

把asyncio.sleep(1)看成是一个耗时1秒的IO操作,在此期间,主线程并未等待,而是去执行EventLoop中其他可以执行的coroutine了,因此可以实现并发执行。

我们用Task封装两个coroutine试试:

importthreadingimportasyncio@asyncio.coroutinedefhello():print('Helloworld!(%s)'%threading.currentThread())yieldfromasyncio.sleep(1)print('Helloagain!(%s)'%threading.currentThread())loop=asyncio.get_event_loop()tasks=[hello(),hello()]loop.run_until_complete(asyncio.wait(tasks))loop.close()

观察执行过程:

Helloworld!(<_MainThread(MainThread,started140735195337472)>)Helloworld!(<_MainThread(MainThread,started140735195337472)>)(暂停约1秒)Helloagain!(<_MainThread(MainThread,started140735195337472)>)Helloagain!(<_MainThread(MainThread,started140735195337472)>)

由打印的当前线程名称可以看出,两个coroutine是由同一个线程并发执行的。

如果把asyncio.sleep()换成真正的IO操作,则多个coroutine就可以由一个线程并发执行。

asyncio案例实战

我们用asyncio的异步网络连接来获取sina、sohu和163的网站首页:

async_wget.py

importasyncio@asyncio.coroutinedefwget(host):print('wget%s...'%host)connect=asyncio.open_connection(host,80)reader,writer=yieldfromconnectheader='GET/HTTP/1.0\r\nHost:%s\r\n\r\n'%hostwriter.write(header.encode('utf-8'))yieldfromwriter.drain()whileTrue:line=yieldfromreader.readline()ifline==b'\r\n':breakprint('%sheader>%s'%(host,line.decode('utf-8').rstrip()))#Ignorethebody,closethesocketwriter.close()loop=asyncio.get_event_loop()tasks=[wget(host)forhostin['www.sina.com.cn','www.sohu.com','www.163.com']]loop.run_until_complete(asyncio.wait(tasks))loop.close()

结果信息如下:

wgetwww.sohu.com...wgetwww.sina.com.cn...wgetwww.163.com...(等待一段时间)(打印出sohu的header)www.sohu.comheader>HTTP/1.1200OKwww.sohu.comheader>Content-Type:text/html...(打印出sina的header)www.sina.com.cnheader>HTTP/1.1200OKwww.sina.com.cnheader>Date:Wed,20May201504:56:33GMT...(打印出163的header)www.163.comheader>HTTP/1.0302MovedTemporarilywww.163.comheader>Server:CdnCacheServerV2.0...

可见3个连接由一个线程通过coroutine并发完成。

小结

asyncio提供了完善的异步IO支持;

异步操作需要在coroutine中通过yield from完成;

本文链接地址:https://www.jiuchutong.com/zhishi/311689.html 转载请保留说明!

上一篇:帝国CMS自动刷新首页的方法(帝国cms自动更新)

下一篇:ecms怎么通过执行sql获取需要的记录(ecs怎么用)

  • qq如何升级(qq如何升级密保)

    qq如何升级(qq如何升级密保)

  • 直播回放怎么下载(直播回放怎么下载下来)

    直播回放怎么下载(直播回放怎么下载下来)

  • k30pro是双扬声器吗(k30pro双扬声器模块)

    k30pro是双扬声器吗(k30pro双扬声器模块)

  • 微信发过的朋友圈怎么编辑(微信发过的朋友圈怎么重新编辑)

    微信发过的朋友圈怎么编辑(微信发过的朋友圈怎么重新编辑)

  • 路由器anonymous是什么意思(路由器显示anonymous连接)

    路由器anonymous是什么意思(路由器显示anonymous连接)

  • 笔记本复制按什么键(笔记本复制按什么键盘)

    笔记本复制按什么键(笔记本复制按什么键盘)

  • a1980是ipad几(a1980是ipad几代几寸)

    a1980是ipad几(a1980是ipad几代几寸)

  • 计算机病毒主要是通过什么传播(计算机病毒主要通过什么途径传播)

    计算机病毒主要是通过什么传播(计算机病毒主要通过什么途径传播)

  • 分屏为什么不能同时播放(分屏为什么不能聊天和看视频)

    分屏为什么不能同时播放(分屏为什么不能聊天和看视频)

  • ps怎么还原工具栏(ps怎么还原快捷键)

    ps怎么还原工具栏(ps怎么还原快捷键)

  • 微信消息显示在屏幕显示(微信消息显示在屏幕顶端)

    微信消息显示在屏幕显示(微信消息显示在屏幕顶端)

  • 苹果xsmax运行内存多大(苹果xsmax运行内存是多少G)

    苹果xsmax运行内存多大(苹果xsmax运行内存是多少G)

  • 淘宝实名认证怎么解除(淘宝实名认证怎么弄)

    淘宝实名认证怎么解除(淘宝实名认证怎么弄)

  • 什么会出现对方正在输入(什么情况会出现对方正在通话中)

    什么会出现对方正在输入(什么情况会出现对方正在通话中)

  • 怎么设置页面为16开(怎么设置页面为a4纸)

    怎么设置页面为16开(怎么设置页面为a4纸)

  • oppor17投屏功能怎么用(oppor17手机投射屏幕教程)

    oppor17投屏功能怎么用(oppor17手机投射屏幕教程)

  • 华为手机怎么传视频到电脑(华为手机怎么传输数据到苹果手机)

    华为手机怎么传视频到电脑(华为手机怎么传输数据到苹果手机)

  • 安卓低电量模式有什么用(安卓低电量模式会影响网络吗)

    安卓低电量模式有什么用(安卓低电量模式会影响网络吗)

  • 滴滴出行预付款啥意思(滴滴出行预付款能退回来吗)

    滴滴出行预付款啥意思(滴滴出行预付款能退回来吗)

  • 洋淘秀什么意思(淘宝洋淘秀对买家有啥好处)

    洋淘秀什么意思(淘宝洋淘秀对买家有啥好处)

  • oppo手机使用记录查看(oppo手机使用记录怎么查看足迹)

    oppo手机使用记录查看(oppo手机使用记录怎么查看足迹)

  • oppoa9虚拟按键怎么设置(oppoa91虚拟按键)

    oppoa9虚拟按键怎么设置(oppoa91虚拟按键)

  • 苹果手机怎么看压缩文件(苹果手机怎么看内存空间)

    苹果手机怎么看压缩文件(苹果手机怎么看内存空间)

  • Vue3 项目中使用setup()函数报错,script setup cannot contain ES module exports(vue3使用教程)

    Vue3 项目中使用setup()函数报错,script setup cannot contain ES module exports(vue3使用教程)

  • 什么是所得税税负
  • 固定资产清理应该在年报中怎么填写
  • 借款合同印花税减免优惠政策2023
  • 公司被员工劳动仲裁
  • 网银数字证书年费计入什么科目
  • 非财政补助结余分配借贷方向
  • 销售自产设备税率
  • 住房公积金的会计处理
  • 借款超期不还利息的法律规定
  • 已认证未入账的分录
  • 购入无形资产产生的咨询费
  • 永续债的利息会计处理
  • 第一季度盈利第二季度亏损全年盈利
  • 烟酒销售公司要交哪些税
  • 物业服务合同印花算什么类型
  • 税收分类编码选错了没事吧
  • 转让集体土地所有权
  • 汇算清缴是啥
  • 公司注销过了公示期不去有问题
  • 预缴纳税申报失败怎么办
  • 生产企业出租设备如何开票
  • 企业取得被投资单位的长期股权可以享有
  • 税务年报网上怎么申报小微企业
  • 供应商是收款人还是付款人
  • 应收账款转营业外收入怎么写申请
  • 企业所得税是什么时候计提
  • 社保公积金代缴
  • 购买货车预付保险怎么算
  • 收到一张增值税红冲发票
  • 库存现金银行存款用什么凭证
  • 代销商品手续费计入什么科目
  • linux的pipe
  • 苹果mac修改用户名和密码
  • php add
  • xp系统可以安装cad吗
  • php__call
  • 存货的采购成本包括
  • vue前端后端
  • 子公司注销母子关系流程
  • 固定资产支出计入什么科目
  • 外贸企业账务处理方法
  • 发票未报销可以退税吗
  • 以发行股票作为对价取得企业的股权
  • 租赁合同印花税税率2023
  • db2with
  • mysql如何开启
  • 本月发料凭证会计分录
  • 长期应收款计提减值
  • 社区居委会有哪些成员
  • 跨期费用账务处理
  • 小规模纳税人销售要交税吗
  • 员工拿发票报销怎么做账
  • 金蝶软件标准版多少
  • 小规模纳税人发票可以抵扣吗
  • 教育机构的咨询
  • 听妈妈讲那过去的事情讲课
  • 账簿设置方法
  • 什么是记账凭证?有哪些分类
  • mysqld mysql
  • xp系统如何安装软件
  • ghost重装步骤
  • 如何设置win10自动登录
  • linux批量杀进程 awk
  • linux命令光标移动到末尾
  • 如何刷硬盘使用时间
  • win10右键菜单快捷键
  • windows7 sp1升级包
  • unity对象池优缺点
  • dos cat命令
  • nodejs性能对比
  • 安卓核心架构
  • css美化表单 案例
  • web开发css
  • unity怎么把文件导入项目
  • 使用node写接口
  • python smtplib模块详解
  • 进口汽车零部件编码查询
  • 地税全国联网了吗
  • 落实措施对吗
  • 杭州国税电话
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设