百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

Python高效率编程之协程的使用 python 协程 yield

lipiwang 2024-11-01 14:09 6 浏览 0 评论

是一种用户态的轻量级线程,本质上是单线程。

协程允许一个执行过程A中断,然后转到执行过程B,在适当的时候再一次转回来,有点类似于多线程

协程的数量理论上可以是无限个,而且没有线程之间的切换动作,执行效率比线程高。

协程在Python中用到的是自带的标准库asyncio

以下介绍协程中的常用术语:

1、event_loop(事件循环)

事件循环,相当于一个无限循环

后面讲的协程函数都要注册到这个循环上才能运行

当满足条件发生的时候(如前一个协程对象阻塞挂起时),就会调用对应的处理方法

Python创建事件循环,示例1:

loop = asyncio.get_event_loop()

2、async和await

这两个关键字常用来修饰函数,被修饰的函数称为协程函数

协程函数的调用方式和普通函数相同,只不过调用协程函数并不会立即执行函数体内的内容,会生成一个coroutine协程对象(解释见下方)

这个协程对象需要放入event-loop事件循环中调度执行

Python代码示例2:

async def func(url):
    print(url)
    await asyncio.sleep(1)

async放在函数定义的开头;await放在函数内部,用在需要挂起等待的位置,告诉cpu执行到该位置时要切换到其他任务执行。

3、Coroutine(协程)

在Python中指代协程对象

需要将协程对象需要放入event-loop事件循环中调度执行

Python代码示例3:

import asyncio

async def func(url):
    print(url)
    await asyncio.sleep(1)
loop = asyncio.get_event_loop()    
loop.run_until_complete(func('http://www.netbian.com/meinv/'))

4、Task

Task任务对协程进一步封装,其中包含任务的各种状态。(比如是否是挂起状态) 协程对象不能直接运行,在注册事件循环的时候,其实是run_until_complete方法将协程包装成为了一个任务(task)对象。

5、Future

Future代表将来执行或没有执行的任务的结果。它和task上没有本质的区别 通常不需要在应用程序级别代码中创建Future对象。

Python代码示例5:

import asyncio

urls = [f"http://www.netbian.com/meinv/index_{page}.htm" for page in range(1, 178)]


async def func(url):
    print(url)
    await asyncio.sleep(1)


async def main():
    tasks = [asyncio.ensure_future(func(url)) for url in urls]
    results = await asyncio.gather(*tasks)


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

注意:

这段代码是我们最终在python里面常写的代码,我们定义一个main函数,函数内部用asyncio.ensure_future来创建Future对象列表,利用asyncio.gather函数来并发运行这些任务。

asyncio.gather还会返回协程函数的返回值,顺序和我们加入的任务顺序相同。

最后用loop.run_until_complete(main())调用这个主函数即可。

相关推荐

ubuntu单机安装open-falcon极度详细操作

备注:以下操作均由本人实际操作并得到验证,喜欢的同学可尝试操作安装。步骤一1.1环境准备(使用系统:ubuntu18.04)1.1.1安装redisubuntu下安装(参考借鉴:https://...

Linux搭建promtail、loki、grafana轻量日志监控系统

一:简介日志监控告警系统,较为主流的是ELK(Elasticsearch、Logstash和Kibana核心套件构成),虽然优点是功能丰富,允许复杂的操作。但是,这些方案往往规模复杂,资源占用高,...

一文搞懂,WAF阻止恶意攻击的8种方法

WAF(Web应用程序防火墙)是应用程序和互联网流量之间的第一道防线,它监视和过滤Internet流量以阻止不良流量和恶意请求,WAF是确保Web服务的可用性和完整性的重要安全解决方案。它...

14配置appvolume(ios14.6配置文件)

使用AppVolumes应用程序功能,您可以管理应用程序的整个生命周期,包括打包、更新和停用应用程序。您还可以自定义应用程序分配,以向最终用户提供应用程序的特定版本14.1安装appvolume...

目前流行的缺陷管理工具(缺陷管理方式存在的优缺点)

摘自:https://blog.csdn.net/jasonteststudy/article/details/7090127?utm_medium=distribute.pc_relevant.no...

开源数字货币交易所开发学习笔记(2)——SpringCloud

前言码云(Gitee)上开源数字货币交易所源码CoinExchange的整体架构用了SpringCloud,对于经验丰富的Java程序员来说,可能很简单,但是对于我这种入门级程序员,还是有学习的必要的...

开发JAX-RPC Web Services for WebSphere(下)

在开发JAX-RPCWebServicesforWebSphere(上)一文中,小编为大家介绍了如何创建一个Web服务项目、如何创建一个服务类和Web服务,以及部署项目等内容。接下来小编将为大...

CXF学习笔记1(cxf client)

webservice是发布服务的简单并实用的一种技术了,个人学习了CXF这个框架,也比较简单,发布了一些笔记,希望对笔友收藏并有些作用哦1.什么是webServicewebService让一个程序可...

分布式RPC最全详解(图文全面总结)

分布式通信RPC是非常重要的分布式系统组件,大厂经常考察的Dubbo等RPC框架,下面我就全面来详解分布式通信RPC@mikechen本篇已收于mikechen原创超30万字《阿里架构师进阶专题合集》...

Oracle WebLogic远程命令执行0day漏洞(CVE-2019-2725补丁绕过)预警

概述近日,奇安信天眼与安服团队通过数据监控发现,野外出现OracleWebLogic远程命令执行漏洞最新利用代码,此攻击利用绕过了厂商今年4月底所发布的最新安全补丁(CVE-2019-2725)。由...

Spring IoC Container 原理解析(spring中ioc三种实现原理)

IoC、DI基础概念关于IoC和DI大家都不陌生,我们直接上martinfowler的原文,里面已经有DI的例子和spring的使用示例《InversionofControlContainer...

Arthas线上服务器问题排查(arthas部署)

1Arthas(阿尔萨斯)能为你做什么?这个类从哪个jar包加载的?为什么会报各种类相关的Exception?我改的代码为什么没有执行到?难道是我没commit?分支搞错了?遇到问题无法在...

工具篇之IDEA功能插件HTTP_CLENT(idea2021插件)

工具描述:Java开发人员通用的开发者工具IDEA集成了HTTPClient功能,之后可以无需单独安装使用PostMan用来模拟http请求。创建方式:1)简易模式Tools->HTTPCl...

RPC、Web Service等几种远程监控通信方式对比

几种远程监控通信方式的介绍一.RPCRPC使用C/S方式,采用http协议,发送请求到服务器,等待服务器返回结果。这个请求包括一个参数集和一个文本集,通常形成“classname.meth...

《github精选系列》——SpringBoot 全家桶

1简单总结1SpringBoot全家桶简介2项目简介3子项目列表4环境5运行6后续计划7问题反馈gitee地址:https://gitee.com/yidao620/springbo...

取消回复欢迎 发表评论: