python异步协程async调用过程图解

1.背景:

项目中有用到协程,但是对于协程,线程,进程的区别还不是特别了解,所以用图示的方式画了出来,用于理清三者的概念。

2.概念理解:

2.1协程,线程,进程包含关系
  • 一个系统可以有多个进程
  • 一个进程可以有多个线程(多个线程为了提高进程的资源利用率)
  • 一个线程可以有多个协程(多个协程为了提高线程的资源利用率)

2.2 共享资源范围 ,隔离性, 通信方式,适用场景对比

PS:该表从Kimi拷贝

名称共享资源范围 隔离性通信方式适用场景
进程独立内存空间、文件描述符、系统资源管道、消息队列、共享内存、套接字适用于需要高隔离性和独立资源的场景,如多用户环境或需要保护数据安全的场景。
线程进程内存空间、文件描述符、系统资源共享内存、互斥锁、条件变量适用于需要共享内存和高效通信的场景,如多任务处理或计算密集型任务。
协程线程内存空间、文件描述符、系统资源 非常低异步机制(awaitasyncio.Queue适用于 I/O 密集型任务,如网络请求、文件读写等,可以高效地利用单线程资源,避免线程切换的开销。

3,协程执行过程示意图

3.1 执行代码
#异步调用
import asyncioasync def model_gen(task,time):# 模拟异步过程print('进入' + task)await asyncio.sleep(time)  # 假设模型生成需要5秒print('处理继续'+ task)await asyncio.sleep(time)  # 假设模型生成需要5秒print('完成' + task)return task+'完成'async def main(name):# 异步调用print(name)#同步函数:asyncio.create_task() 是一个同步函数,它会立即返回一个 Task 对象。#返回的Task对象会被事件循环调度执行,asyncio.create_task() 本身不会等待任务完成。#asyncio.create_task() 提供了一种简单的方式来将协程包装成任务并提交到事件循环中,而不会阻塞调用它的线程。task1 = asyncio.create_task(model_gen('task1',4))print('create task1')task2 = asyncio.create_task(model_gen('task2',2))print('create task2')# 等待两个任务完成,并获取结果# await 是一个异步操作,当在协程中遇到 await 表达式时,当前协程会暂停执行,并将控制权交还给事件循环。result2 = await task2  # 协程挂载,task2执行完毕之后,才继续执行后续作业print('hello')result1 = await task1  # task1执行完毕之后,才能继续执行后续代码# 打印结果print("所有任务完成!")print(result1)print(result2)#asyncio.run是同步函数,会阻塞当前线程,所以main('main1')全部执行完毕之后,才能执行main2的代码
asyncio.run(main('main1'))
asyncio.run(main('main2'))
3.2 执行结果

main1
create task1
create task2
进入task1
进入task2
处理继续task2
处理继续task1
完成task2
hello
完成task1
所有任务完成!
task1完成
task2完成
main2
create task1
create task2
进入task1
进入task2
处理继续task2
处理继续task1
完成task2
hello
完成task1
所有任务完成!
task1完成
task2完成

3.3 执行图解及理解

图解如下:左边三列是协程,第四列是线程的占用情况,最右边是执行结果输出。

个人理解:(如果有问题,欢迎指正,目前循环事件如何确定执行哪个协程的这一块还没有研究)

1)每个协程启动之后,一直执行,直到挂起(比如await),可以是挂起多长时间,也可以是等待某个操作完成。挂起结束之后,协程变为可调用的状态,供事件循环调用
2)事件循环从可调用的协程中,将其放到协程进行执行,直到该协程挂起,再取下一个可调用协程执行。
3)每次协程被调用之后,会一直执行直到下一次挂起(比如await),所以如果协程中有一个非常耗时的同步操作,就有可能导致包含该操作的协程一直占用线程,导致其他协程一直等待。所以写异步程序时候,需要确认是否有非常耗时的同步操作。

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

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

相关文章

【React】获取元素距离页面顶部的距离

文章目录 代码实现 代码实现 import { useEffect, useRef, useState } from react;const DynamicPositionTracker () > {const [distance, setDistance] useState(0);const divRef useRef(null);useEffect(() > {const targetDiv divRef.current;if (!targetDiv) re…

26.OpenCV形态学操作

OpenCV形态学操作 形态学操作(Morphological Operations)源自二值图像处理,主要用于分析和处理图像中的结构元素,对图像进行去噪、提取边缘、分割等预处理步骤。OpenCV库中提供了丰富的形态学函数,常见的包括&#xf…

逻辑回归:损失和正则化技术的深入研究

逻辑回归:损失和正则化技术的深入研究 引言 逻辑回归是一种广泛应用于分类问题的统计模型,尤其在机器学习领域中占据着重要的地位。尽管其名称中包含"回归",但逻辑回归本质上是一种分类算法。它的核心思想是在线性回归的基础上添…

大模型面经 | 介绍一下CLIP和BLIP

大家好,我是皮先生!! 今天给大家分享一些关于大模型面试常见的面试题,希望对大家的面试有所帮助。 往期回顾: 大模型面经 | 春招、秋招算法面试常考八股文附答案(RAG专题一) 大模型面经 | 春招、秋招算法面试常考八股文附答案(RAG专题二) 大模型面经 | 春招、秋招算法…

【MCP】第二篇:IDE革命——用MCP构建下一代智能工具链

【MCP】第二篇:IDE革命——用MCP构建下一代智能工具链 一、引言二、IDE集成MCP2.1 VSCode2.1.1 安装VSCode2.1.2 安装Cline2.1.3 配置Cline2.1.4 环境准备2.1.5 安装MCP服务器2.1.5.1 自动安装2.1.5.2 手动安装 2.2 Trae CN2.2.1 安装Trae CN2.2.2 Cline使用2.2.3 内…

【新能源科学与技术】MATALB/Simulink小白教程(一)实验文档【新能源电力转换与控制仿真】

DP读书:新能源科学与工程——专业课「新能源发电系统」 2025a 版本 MATLAB下面进入正题 仿真一:Buck 电路一、仿真目的二、仿真内容(一)Buck电路基本构成及工作原理(二)Buck电路仿真模型及元件连接&#xf…

BootStrap:首页排版(其一)

今天我要介绍的是在BootStrap中有关于首页排版的内容知识点,即(模态框,选项卡)。 模态框: 模态框经过了优化,更加灵活,以弹出对话框的形式出现,具有最小和最实用的功能集。 在运行…

Spring Data

目录 一、Spring Data 简介与生态概览 什么是 Spring Data? Spring Data 与 Spring Data JPA 的关系 Spring Data 家族:JPA、MongoDB、Redis、Elasticsearch、JDBC、R2DBC…… 与 MyBatis 的本质差异(ORM vs SQL 显式控制) 二…

建筑末端配电回路用电安全解决方案

一、电气火灾的严峻现状 根据国家应急管理部消防救援局的数据,电气火灾长期占据各类火灾原因之首,2021年占比高达50.4%。其中,末端配电回路因保护不足、监测手段落后,成为火灾高发隐患点。私拉电线、线路老化、接触不良、过载等问…

华为开发岗暑期实习笔试(2025年4月16日)

刷题小记: 第一题怀疑测试样例不完整,贪心法不应该能够解决该题。第二题使用0-1BFS解决单源最短路径的问题,往往搭配双端队列实现。第三题是运用动态规划解决最大不重叠子区间个数的问题,难点在于满足3重判断规则,所需…

Rust: 从内存地址信息看内存布局

内存布局其实有几个:address(地址)、size(大小)、alignment(对齐位数,2 的自然数次幂,2,4,8…)。 今天主要从address来看内存的布局。 说明&…

每日一题算法——两个数组的交集

两个数组的交集 力扣题目链接 我的解法&#xff1a;利用数组下标。 缺点&#xff1a;当取值范围很大时&#xff0c;浪费空间。 class Solution { public:vector<int> intersection(vector<int>& nums1, vector<int>& nums2) {int count1[1001]{0…

c++ 互斥锁

为练习c 线程同步&#xff0c;做了LeeCode 1114题. 按序打印&#xff1a; 给你一个类&#xff1a; public class Foo {public void first() { print("first"); }public void second() { print("second"); }public void third() { print("third"…

山东大学软件学院创新项目实训开发日志(20)之中医知识问答自动生成对话标题bug修改

在原代码中存在一个bug&#xff1a;当前对话的标题不是现有对话的用户的第一段的前几个字&#xff0c;而是历史对话的第一段的前几个字。 这是生成标题的逻辑出了错误&#xff1a; 当改成size()-1即可

WSL2-Ubuntu22.04下拉取Docker MongoDB镜像并启动

若未安装docker可参考此教程&#xff1a;可以直接在wsl上安装docker吗&#xff0c;而不是安装docker desktop&#xff1f;-CSDN博客 1. 拉取镜像 docker pull mongo:latest 2.打开网络加速&#xff0c;再次拉取镜像 3.创建docker-compose.yml 进入vim编辑器后输入i进行编辑&a…

中通 Redis 集群从 VM 迁移至 PVE:技术差异、PVE 优劣势及应用场景深度解析

在数字化转型浪潮下&#xff0c;企业对服务器资源的高效利用与成本控制愈发重视。近期&#xff0c;中通快递将服务器上的 Redis 集群服务从 VM&#xff08;VMware 虚拟化技术&#xff09;迁移至 PVE&#xff08;Proxmox VE&#xff09;&#xff0c;这一技术举措引发了行业广泛关…

Prometheus+Grafana实时监控系统各项指标

一、监控架构设计 核心组件与数据流 Prometheus&#xff1a;时序数据采集、存储与告警规则管理Node Exporter&#xff1a;采集主机指标&#xff08;CPU、内存、磁盘、网络等&#xff09;数据库Exporter&#xff1a;如 mysqld_exporter、postgres_exporterGrafana&#xff1a;…

[密码学基础]GMT 0029-2014签名验签服务器技术规范深度解析

GMT 0029-2014签名验签服务器技术规范深度解析 引言 在数字化转型和网络安全需求激增的背景下&#xff0c;密码技术成为保障数据完整性与身份认证的核心手段。中国密码管理局发布的GMT 0029-2014《签名验签服务器技术规范》&#xff0c;为签名验签服务器的设计、开发与部署提…

多路转接select服务器

目录 select函数原型 select服务器 select的缺点 前面介绍过多路转接就是能同时等待多个文件描述符&#xff0c;这篇文章介绍一下多路转接方案中的select的使用 select函数原型 #include <sys/select.h> int select(int nfds, fd_set *readfds, fd_set *writefds, f…

QT6 源(45):分隔条 QSplitter 允许程序的用户修改布局,程序员使用 IDE时,就是分隔条的用户,以及其 QSplitter 源代码

&#xff08;1&#xff09; &#xff08;2&#xff09;本类的继承关系如下&#xff0c;所以说分隔条属于容器&#xff1a; &#xff08;3&#xff09;本类的属性&#xff1a; &#xff08;4&#xff09; 这是一份 QSplitter 的举例代码&#xff0c;注意其构造函数时候的传参&am…