python协成_Python协程(上)

几个概念:

event_loop 事件循环:程序开启一个无限的循环,程序员会把一些函数注册到事件循环上。当满足事件发生的时候,调用相应的协程函数。

coroutine 协程:协程对象,指一个使用async关键字定义的函数,它的调用不会立即执行函数,而是会返回一个协程对象。协程对象需要注册到事件循环,由事件循环调用。

task 任务:一个协程对象就是一个原生可以挂起的函数,任务则是对协程进一步封装,其中包含任务的各种状态。

future: 代表将来执行或没有执行的任务的结果。它和task上没有本质的区别

async/await 关键字:python3.5 用于定义协程的关键字,async定义一个协程,await用于挂起阻塞的异步调用接口。

定义协程

通过async关键字定义一个协程(coroutine),协程也是一种对象。协程不能直接运行,需要把协程加入到事件循环(loop),由后者在适当的时候调用协程。asyncio.get_event_loop方法可以创建一个事件循环,然后使用run_until_complete将协程注册到事件循环,并启动事件循环。

import time

import asyncio

async def task(x):

print('Waiting: ', x)

await asyncio.sleep(x)

start = time.time()

coroutine = task(2)

loop = asyncio.get_event_loop()

loop.run_until_complete(coroutine)

print('用时:', time.time()-start)

创建task

协程对象不能直接运行,在注册事件循环的时候,其实是run_until_complete方法将协程包装成为了一个任务(task)对象。所谓task对象是Future类的子类。保存了协程运行后的状态,用于未来获取协程的结果。

import asyncio

import time

async def task(x):

print('Waiting: ', x)

await asyncio.sleep(x)

start = time.time()

coroutine = task(2)

loop = asyncio.get_event_loop()

task = loop.create_task(coroutine) # task = asyncio.ensure_future(coroutine)

print(task)

loop.run_until_complete(task)

print(task)

print('用时:', time.time() - start)

daf9d1af2950ff7903e186b656db5739.png

创建task后,task在加入事件循环之前是pending状态,执行之后是finished状态。

asyncio.ensure_future(coroutine) 和loop.create_task(coroutine)

都可以创建一个task,run_until_complete的参数是一个futrue对象。当传入一个协程,其内部会自动封装成task,task是Future的子类。isinstance(task, asyncio.Future)将会输出True。

绑定回调

绑定回调,在task执行完毕的时候可以获取执行的结果,回调的最后一个参数是future对象,通过该对象可以获取协程返回值。如果回调需要多个参数,可以通过偏函数导入。

import time

import asyncio

async def task(x):

print('Waiting: ', x)

await asyncio.sleep(x)

return 'Done after {}s'.format(x)

def callback(future):

print('Callback: ', future.result())

coroutine = task(2)

loop = asyncio.get_event_loop()

task = asyncio.ensure_future(coroutine)

task.add_done_callback(callback)

loop.run_until_complete(task)

coroutine执行结束时候会调用回调函数。并通过参数future获取协程执行的结果。我们创建的task和回调里的future对象,实际上是同一个对象。

future 与 result

回调中我们使用了future对象的result方法。前面不绑定回调的例子中,我们可以看到task有fiinished状态。在那个时候,可以直接读取task的result方法。

async def task(x):

print('Waiting {}'.format(x))

return 'Done after {}s'.format(x)

coroutine = task(2)

loop = asyncio.get_event_loop()

task = asyncio.ensure_future(coroutine)

loop.run_until_complete(task)

# task.result()是协程对象的返回值

print('Task result: {}'.format(task.result()))

24a62557d0b96a366be8cc18502850fa.png

阻塞和await

使用async可以定义协程对象,使用await可以针对耗时的操作进行挂起,就像生成器里的yield一样,函数让出控制权。协程遇到await,事件循环将会挂起该协程,执行别的协程,直到其他的协程也挂起或者执行完毕,再进行下一个协程的执行。

耗时的操作一般是一些IO操作,例如网络请求,文件读取等。我们使用asyncio.sleep函数来模拟IO操作。协程的目的也是让这些IO操作异步化。

import asyncio

import time

async def task(x):

print('Waiting: ', x)

await asyncio.sleep(x)

return 'Done after {}s'.format(x)

start = time.time()

coroutine = task(2)

loop = asyncio.get_event_loop()

task = asyncio.ensure_future(coroutine)

loop.run_until_complete(task)

print('Task result: ', task.result())

print('Time: ', time.time() - start)

在 sleep的时候,使用await让出控制权。即当遇到阻塞调用的函数的时候,使用await方法将协程的控制权让出,以便loop调用其他的协程。现在我们的例子就用耗时的阻塞操作了。

并发和并行

asyncio实现并发,就需要多个协程来完成任务,每当有任务阻塞的时候就await,然后其他协程继续工作。创建多个协程的列表,然后将这些协程注册到事件循环中。

import asyncio

import time

async def task(x):

print('Waiting: ', x)

await asyncio.sleep(x)

return 'Done after {}s'.format(x)

start = time.time()

coroutine1 = task(1) #

coroutine2 = task(2)

coroutine3 = task(4)

loop = asyncio.get_event_loop()

tasks = [ # 创建任务

asyncio.ensure_future(coroutine1),

asyncio.ensure_future(coroutine2),

asyncio.ensure_future(coroutine3)

]

loop.run_until_complete(asyncio.wait(tasks))

for task in tasks:

print('Task result: ', task.result())

print('Time: ', time.time() - start)

# 当任务比较多的时候,可以使用列表生成式,效果是一样的。

import asyncio

import time

async def task(x):

print('Waiting: ', x)

await asyncio.sleep(x)

return 'Done after {}s'.format(x)

start = time.time()

loop = asyncio.get_event_loop()

tasks = [asyncio.ensure_future(task(i)) for i in [1,2,4]]

loop.run_until_complete(asyncio.wait(tasks))

for task in tasks:

print('Task result: ', task.result())

print('Time: ', time.time() - start)

dda0ca77c240dce53f67594890186022.png

使用aysncio实现了并发。asyncio.wait(tasks) 也可以使用 asyncio.gather(*tasks) ,前者接受一个task列表,后者接收一堆task。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/558568.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python参数检验框架_基于python的人员识别检测框架研究

import numpy as np # 数据处理的库 Numpyimport cv2 # 图像处理的库 OpenCvimport osimport shutilimport _threadimport wximport csvfrom importlib import reloadfrom skimage import io as iioimport face_recognize_punchcardimport sys# 创建 cv2 摄像头对象#…

js父元素获取子元素img_css,前端_父标签div中包含一个子元素img标签,子元素div标签,为什么img要加上浮动,子元素div才会处于正常位置?,css,前端 - phpStudy...

父标签div中包含一个子元素img标签,子元素div标签,为什么img要加上浮动,子元素div才会处于正常位置?dom结构如图img加上float 子元素div显示正常。不加float div显示错位。附上我写的一个dome测试用的,大家可本地看下究…

android运营商获取本机号码_一键登录已成大势所趋,Android端操作指南来啦!

根据极光(Aurora Mobile)发布的《2019年Q2移动互联网行业数据研究报告》,2019年第二季度,移动网民人均安装APP总量已达56款。面对如此繁多的APP,想在用户的手机中占据一席之地,移动开发者们就不得不努力提升用户体验。而现实却是&…

mysql数据库中删除数据用什么语句_mysql数据库删除数据语句

{"moduleinfo":{"card_count":[{"count_phone":1,"count":1}],"search_count":[{"count_phone":4,"count":4}]},"card":[{"des":"阿里云数据库专家保驾护航,为用户…

spring批量写入mysql数据库_MyBatis-spring和spring JDBC批量插入Mysql的效率比较

工具框架用spring-batch,数据库是mysql(未做特殊优化)。比较数据框架mybatis和spring jdbc的插入效率。Mybatis三种实现:1、mybatis的官方写法Java代码publicvoidbatchInsert1(List poilist)throwsException {SqlSession sqlSession sqlSessionFactory.…

mysql启动触发器_MYSQL中禁用/启动触发器

在使用MYSQL过程中,经常会使用到触发器,但是有时使用不当会造成一些麻烦。有没有一种办法可以控制触发器的调用呢?触发器顾名思义就是数据库在一定的调条件自动调用的SQL语句,触发器拒绝了人工调用的过程,由数据库MYSQ…

mysql数据库权威指南_MySQL_MySQL权威指南读书笔记(三),第二章:MYSQL数据库里面的数 - phpStudy...

MySQL权威指南读书笔记(三)第二章:MYSQL数据库里面的数据用想用好MYSQL,就必须透彻理解MYSQL是如何看待和处理数据的。本章主要讨论了两个问题:一是SQL所能处理的数据值的类型;二是这些数据类型…

mysql 批量替换 所有表_[收藏]批量替换一个数据库中所有表中所有记录

/***********批量替换一个数据库中所有表中所有记录************/declare delStr nvarchar(500)set delStr这里是要替换的字符/**********以下为操作实体************/set nocount ondeclare tableName nvarchar(100),columnName nvarchar(100),tbID int,iRow int,iResult intd…

java偶数和_Java编程计算1-100之间所有偶数的和。

展开全部 public class Demo05ShiCao{public static void main(String[] args){int sum1 = 0; for(int i = 1; i <= 100; i++){if(i % 2 == 0){sum1 +=i; } } System.out.println("结果e5a48de588b63231313335323631343130323136353331333366303138是:" + sum1);…

金额转换java_java金额转换

像商品价格&#xff0c;订单&#xff0c;结算都会涉及到一些金额的问题&#xff0c;为了避免精度丢失通常会做一些处理&#xff0c;常规的系统中金额一般精确到小数点后两位&#xff0c;也就是分&#xff1b;这样数据库在设计的时候金额就直接存储整型数据类型&#xff0c;前端…

java 栈 大小_java – JVM堆栈大小规范

Question, what does 1 MB stack size states in JVM as I have no idea what size a stack frame of?1 MB默认线程堆栈大小意味着每个线程默认具有1MB(1048576字节)的堆栈空间.例外情况是,如果您的代码使用其中一个Thread构造函数创建一个线程,您可以在其中提供堆栈大小参数.…

java bloomfilter_爬虫技术之——bloom filter(含java代码)

在爬虫系统中&#xff0c;在内存中维护着两个关于URL的队列&#xff0c;ToDo队列和Visited队列&#xff0c;ToDo队列存放的是爬虫从已经爬取的网页中解析出来的即将爬取的URL&#xff0c;但是网页是互联的&#xff0c;很可能解析出来的URL是已经爬取到的&#xff0c;因此需要VI…

java new对象 =null_在Java中将对象分配为null会影响垃圾回收吗?

通常&#xff0c;没有。但就像所有事情一样&#xff1a;这取决于。如今&#xff0c;Java中的GC非常好&#xff0c;所有内容都应该在不再可用后立即清理。这就是在为局部变量留下一个方法之后&#xff0c;以及当不再为字段引用类实例时。如果您知道它将继续引用&#xff0c;则只…

java php js_【javascript/PHP】当一个JavaScripter初次进入PHP的世界,他将看到这样的风景...

本文将从以下11点介绍javascript和PHP在基础语法和基本操作上的异同&#xff1a;1.数据类型的异同2.常量和变量的定义的不同&#xff0c;字符串连接运算符不同3.对象的创建方法的不同4.PHP与JS在变量声明提升和函数声明提升的差异5.var在JS和PHP中使用的差异6.PHP和JS在访问对象…

java so jnienv_JNI初步(五)jni ndk 一个.so文件依赖另一个.so文件的写法

注意&#xff1a;本文是在ndk环境下编写1.写native类声明native方法package com.godv.audiosuc;public class NativePlayers {static{System.loadLibrary("JNI_ANDROID_AUDIOS");System.loadLibrary("JNI_ANDROID_TEST");}//native方法public static nativ…

从零开始学java 框架_从零开始学 Java - 搭建 Spring MVC 框架

如果创建一个 Spring 项目Spring MVC 框架在 Java 的 Web 项目中应该是无人不知的吧&#xff0c;你不会搭建一个 Spring 框架&#xff1f;作为身为一个刚刚学习Java的我都会&#xff0c;如果你不会的话&#xff0c;那可真令人忧伤。1.在 MyEclipse 创建项目后&#xff0c;可以以…

java 系统类型_Java获取操作系统类型

Java获取操作系统完整版系统枚举类&#xff1a;public enum EPlatform {Any("any"),Linux("Linux"),Mac_OS("Mac OS"),Mac_OS_X("Mac OS X"),Windows("Windows"),OS2("OS/2"),Solaris("Solaris"),SunOS…

java的min函数_Java语言实现包含min函数的栈

package stack;import java.util.ArrayList;/*** 实现包含min函数的栈* author DHC* param */public class MinInStack {public static void main(String[] args) {MinInStack newStack new MinInStack();newStack.push(4);newStack.push(6);newStack.push(2);newStack.push(5…

updatepanel失效怎么办_【点滴积累】解决jQuery绑定事件在updatepanel更新后失效的方法...

背景 接到了领导给的一个New Feature&#xff0c;为系统的菜单导航栏进行一些个性化的操作(鼠标移到导航菜单时下方出现子菜单&#xff0c;移到其他的菜单选项时显示该选项的子菜单&#xff0c;隐藏其他子菜单。其次就是当使用鼠标点击一个菜单选项时就把该菜单及其子菜单固定&…

azure mysql on vnet_管理 VNet 终结点 - Azure 门户 - Azure Database for MySQL | Microsoft Docs

您现在访问的是微软AZURE全球版技术文档网站&#xff0c;若需要访问由世纪互联运营的MICROSOFT AZURE中国区技术文档网站&#xff0c;请访问 https://docs.azure.cn.使用 Azure 门户创建和管理 Azure Database for MySQL VNet 服务终结点和 VNet 规则Create and manage Azure D…