websevere服务器从零搭建到上线(一)|阻塞、非阻塞、同步、异步

文章目录

  • 数据准备(阻塞和非阻塞)、数据读写(同步和异步)
    • 小总结(陈硕老师的总结)
  • 知识拓展
    • 同步执行实例
    • 异步编程实例
  • 八股

数据准备(阻塞和非阻塞)、数据读写(同步和异步)

无论是什么样的IO都包含两个阶段:数据准备和数据读写。

我们的网络IO也是同样的,

数据准备:根据系统IO操作的就绪状态(这是在操作系统的角度来讲的)

  • 阻塞
    调用IO方法的线程进入则色状态,
    如果没有数据可读,recv函数是不会返回的,一直等待这个fd上的读缓冲区上被激活;如果它返回说明有数据可以读,接着就是数据读写,走向阶段二:数据读写。
  • 非阻塞
    不会改变线程的状态,通过返回值判断
    如果说我把sockfd设置成非阻塞,recv会直接返回,不会造成当前线程的阻塞

总而言之,我们会在这里编写一个循环,不断让CPU空转,只有真正收到数据的时候才会返回。

//默认阻塞
int size = recv(int socket, void *buffer, size_t length, int flags);
int size = recv(sockfd, buf, 1024, 0);//如果sockfd被设置成非阻塞状态,我们这样去运行程序
//返回值如果是-1,说明有内部错误
size == -1 && errno = EAGAIN//表示连接上了但是远端没有数据,返回的原因是非阻塞IO返回
size == 0 //远端断开链接
size > 0 //表示有这么多数据可读

数据读写:根据应用程序和内核的交互方式(这是在应用层程序的角度讲的)
int size = recv(int socket, void *buffer, size_t length, int flags);
int size = recv(sockfd, buf, 1024, 0);
无论是阻塞模式还是非阻塞模式,只要数据没到,我们是都没有数据可以读的。
等到TCP接受缓冲区(内核)有数据了,说明数据可读,那么我们的recv函数开始接收数据,通过调用这个函数,内核中的数据就开始往用户层的这个buf里面搬运。这里的返回值size就是返回了多少数据。
那么是让操作系统给我读好还是我自己去读呢?其中的参数buf,是用户层的自己定义的buf.

  • 同步
    等到TCP接受缓冲区(内核)有数据了,说明数据可读,那么我们的recv函数开始接收数据,通过调用这个函数,内核中的数据就开始往用户层的这个buf里面搬运。这里的返回值size就是返回了多少数据。
    如果recv没有把内核中缓冲区数据全部搬完的话,是不会返回的。
    这就叫IO同步
char buf[1024] = 0;
int size = recv(sockfd, buf, 1024, 0);
if (size > 0) {buf
}
  • 异步

关于数据的异步读写就不能用recv来举例了,因为recv和send都是同步的IO接口。
异步IO的效率确实高,但是程序比较复杂,出问题的话也不太好定位错误

所谓的异步IO接口就是,首先得有一个sockfd,如果该文件描述符上的数据可读,需要把内核中读缓冲区的数据搬到buf中(操作系统来完成,在同步IO中,是我们自己花时间搬的),如果操作系统完成了所有数据的搬运,通过sigio信号通知应用程序即可

所以我们的应用程序可以完成自己的业务逻辑。等到sigio通知(这个通知不一定是信号,还可以通过回调函数),这个时候说明IO已经准备好了,我们再去执行即可。这是我们异步编程的最大核心。

也就是说我们把数据读写全部委托给了操作系统,不同于之前的同步IO接口,要么就是阻塞在recv,要么就是在循环中空转CPU,等待TCP接收缓冲区全部写入buf。(这里老师举了一个坐飞机取机票的例子来总结同步和异步IO,非常简单形象)

两个典型的异步IO接口:aio_read,aio_write

小总结(陈硕老师的总结)

陈硕大神的原话:在处理IO:在处理 IO 的时候,阻塞和非阻塞都是同步 IO。只有使用了特殊的 API 才是异步 IO。

知识拓展

在我们应用程序进行多线程多进程处理的时候,也就是业务层面的一个并发的同步和异步如何区分呢?

同步:A等待B做完事情,得到返回值,然后继续处理
异步:A操作告诉B操作它感兴趣的事件以及同时方式,A操作继续执行自己的业务逻辑了;等B监听到响应事件发生后,B会通知A,A开始处理响应的数据处理逻辑

同步执行实例

这个示例中,A 等待 B 完成一个任务(如计算一个值),然后使用这个值继续其他操作。

#include <iostream>
#include <thread>
#include <chrono>int performTask(int x) {// 模拟耗时任务std::this_thread::sleep_for(std::chrono::seconds(2));return x * x; // 返回 x 的平方
}int main() {std::cout << "A starts and waits for B to complete..." << std::endl;int result = performTask(5); // A 等待 B 完成std::cout << "B completed with result: " << result << std::endl;std::cout << "A continues with result." << std::endl;// 使用结果进行其他操作std::cout << "Final result: " << result * 2 << std::endl;return 0;
}

异步编程实例

在这个例子中,A 操作发起一个任务给 B,并且继续执行其他事情。当 B 完成任务时,它将结果返回给 A,然后 A 处理这个结果。

#include <iostream>
#include <future>
#include <chrono>int performAsyncTask(int x) {// 模拟耗时任务std::this_thread::sleep_for(std::chrono::seconds(2));return x * x; // 返回 x 的平方
}int main() {std::cout << "A starts and does not wait for B..." << std::endl;std::future<int> futureResult = std::async(std::launch::async, performAsyncTask, 5);// A 继续执行其他操作std::cout << "A is doing other things..." << std::endl;std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟 A 执行其他任务std::cout << "A is still working..." << std::endl;// 等待 B 完成并获取结果int result = futureResult.get();std::cout << "B completed with result: " << result << std::endl;std::cout << "A processes the result." << std::endl;// 使用结果进行其他操作std::cout << "Final result: " << result * 2 << std::endl;return 0;
}

在异步示例中,std::async 创建了一个异步任务,它允许 A 继续执行而不必等待 B 完成。一旦需要结果时,通过调用 futureResult.get() 获取,这将会阻塞直到异步任务完成。在多线程编程中,如果我们的A线程并不关心B线程的返回值和状态,我们甚至可以A直接退出。

八股

首先阐述什么是阻塞、非阻塞、同步、异步:
阻塞非阻塞同步异步描述的都是IO的状态,一个典型的网络IO包含两个阶段,数据准备和数据读写;

举例说明
比如说recv传一个sockfd,buf,buf的大小,

数据准备
数据准备就是说远端是否有数据过来,内核的TCP接受缓冲区中是否有数据可读,

阻塞和非阻塞
当sockfd工作在阻塞模式下的话,当我调用recv如果数据没有就绪,就会阻塞当前的线程,如果sockfd工作在非阻塞状态下,我们调用系统IO接口就会立即返回,如果返回值是-1说明链接异常;
如果工作在非阻塞,我们往往会写一个错误好EAGAIN来捕捉该错误,返回值是0说明连接中断,返回值>0值得就是我们读的数据大小。

数据就绪
如果说远端数据已经准备好了,说明我们需要进行数据的读写,

同步和异步
这个时候操作系统会帮我们把内核的TCP接受缓冲区写入到recv的buf参数中,只有写完了,也就是说我们的应用程序必须等待它拷贝完成,recv才返回,才能执行后续的运行逻辑,这就是同步IO;
如果我们调用aio_read接口就是异步IO,此时我们的线程可以继续执行后面的应用程序逻辑,等到缓冲区数据全部写入到我们的buf中去的时候,aio_read会发送一个sigio信号来告诉我们读数据完毕。这个sigio不仅可以是一个信号,也可以通过回调函数来实现。

在我们应用程序业务层面的并发编程也涉及到同步和异步,虽然角度不同,但是大体的逻辑是一致的,同步的话A程序必须等待B程序执行完毕,异步的话他们可以各自处理自己的业务逻辑,等B执行完,通知A即可

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

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

相关文章

1.6 Java全栈开发前端+后端(全栈工程师进阶之路)-前置课程Jdbc编程,使用Java通过Jdbc对数据库进行基础操作

原理图 用java代码实现连接数据库&#xff08;mysql&#xff09;的操作 因为数据库连接需要使用到API和URL&#xff0c;下面简单介绍下API和URL的概念&#xff0c; API&#xff1a; Application Programming Interface应用程序编程接口&#xff0c;就是一套类库 Java中的AP…

KaiwuDB 解析器之语义解析

KaiwuDB 解析器介绍 解析器是数据库系统的重要组成部分之一&#xff0c;主要的功能是将客户端输入的 SQL 语句分解为语法单元&#xff0c;然后将这些语法单元转化成数据库内部可识别的数据结构&#xff0c;最终生成数据库可以执行的计划。 KaiwuDB 的一条 SQL 执行的整个生命…

SQL 基础 | AVG 函数的用法

在SQL中&#xff0c;AVG()是一个聚合函数&#xff0c;用来计算某个列中所有值的平均值。 它通常与GROUP BY子句一起使用&#xff0c;以便对分组后的数据进行平均值计算。 AVG()函数在需要了解数据集中某个数值列的中心趋势时非常有用。 以下是AVG()函数的一些常见用法&#xff…

Java集合排序

1. 集合排序API 1.1 集合排序概述 集合排序是指对一个集合中的元素按照特定规则进行重新排列&#xff0c;以使得集合中的元素按照预定义的顺序呈现。 在集合排序中&#xff0c;通常需要定义一个比较规则&#xff0c;这个比较规则用于决定集合中的元素在排序后的顺序。元素之间…

本地部署开源白板工具Excalidraw并结合内网穿透远程绘制流程图

文章目录 1. 安装Docker2. 使用Docker拉取Excalidraw镜像3. 创建并启动Excalidraw容器4. 本地连接测试5. 公网远程访问本地Excalidraw5.1 内网穿透工具安装5.2 创建远程连接公网地址5.3 使用固定公网地址远程访问 本文主要介绍如何在Ubuntu系统使用Docker部署开源白板工具Excal…

渗透测试工具--awvs

安装 pull 这个镜像&#xff0c;注&#xff1a;内部映射端口 3443 软件页面 UserName: awvsawvs.lan PassWord: Awvsawvs.lan 或 使用以下命令无脑安装 bash <(curl -sLk https://www.fahai.org/aDisk/Awvs/check.sh) xrsec/awvs:preview 样式如下 若未成功&#xff0…

【网络原理】HTTPS 的工作过程

系列文章目录 【网络通信基础】网络中的常见基本概念 【网络编程】网络编程中的基本概念及Java实现UDP、TCP客户端服务器程序&#xff08;万字博文&#xff09; 【网络原理】UDP协议的报文结构 及 校验和字段的错误检测机制&#xff08;CRC算法、MD5算法&#xff09; 【网络…

面试集中营—Redis架构篇

一、Redis到底是多线程还是单线程 1、redis6.0版本之前的单线程&#xff0c;是指网络请求I/O与数据的读写是由一个线程完成的&#xff1b; 2、redis6.0版本升级成了多线程&#xff0c;指的是在网络请求I/O阶段应用的多线程技术&#xff1b;而键值对的读写还是由单线程完成的。所…

【prometheus】Pushgateway安装和使用

目录 一、Pushgateway概述 1.1 Pushgateway简介 1.2 Pushgateway优点 1.3 pushgateway缺点 二、测试环境 三、安装测试 3.1 pushgateway安装 3.2 prometheus添加pushgateway 3.3 推送指定的数据格式到pushgateway 1.添加单条数据 2.添加复杂数据 3.SDk-prometheus-…

C语言 举例说明循环嵌套

今天 我们来说循环的嵌套 如果一个循环体内 又包含了另一个循环结构 我们称之为循环的嵌套 我们之前学的 While do-while for 都可以进行相互的嵌套 如下图 在 While 循环语句中再嵌套一个 While 循环语句 do-while 中嵌套 do-while for中嵌套 for 例如 我们做一个九九乘法…

Oracle Database 23ai 正式发布,超级巨兽(集关系型、向量、文档、图、缓存、分布式数据库一体的全能数据库)

Oracle23c改名为Oracle23ai&#xff0c;也意味着Oracle数据库正式从Cloud进入AI时代。Oracle23ai版本是一个超级巨兽&#xff0c;简单总结下&#xff1a; AI能力&#xff1a;内置向量数据库&#xff0c;内置ONNX模型数据处理&#xff0c;内置Text2SQL&#xff0c;内置的机器学习…

QT5之lambda+内存回收机制

使用lambda需要 配置c11 所以在点.pro文件里面配置添加如下 CONFIG c11 使用到qDebug 打印包含头文件 #include<QDebug> lambda 表达式使用 代替槽如下 #include "mainwidget.h" #include<QPushButton> #include<QDebug> mainWidget::mainWid…

js模块化:修改导入模块的内容,会有影响吗?

起因 element-ui的popper组件相关的层级&#xff0c;是使用popup-manager来统一管理的。 之前试图在自己的组件里导入并使用element-ui的popup-manager&#xff0c;但是层级老是和element-ui组件的层级冲突&#xff0c;看了下源码&#xff0c;竟意外发现&#xff0c;使用popu…

毕业设计参考-PyQt5-YOLOv8-鱼头鱼尾鱼长测量程序,OpenCV、Modbus通信、YOLO目标检测综合应用

“PyQt5-YOLOv8-鱼头鱼尾鱼长测量程序”是一个特定的软件程序&#xff0c;用于通过图像处理和目标检测技术来测量鱼类的长度。 视频效果&#xff1a; 【毕业设计】基于yolo算法与传统机器视觉的鱼头鱼尾识别_哔哩哔哩_bilibili 这个程序结合了多种技术&#xff1a; 1. OpenCV…

【Linux极简教程】常见实用命令不断更新中......

【Linux极简教程】常见实用命令不断更新中...... 常见问题1.Waiting for cache lock: Could not get lock /var/lib/dpkg/lock. It is held by process xxxx(dpkg) 常见问题 1.Waiting for cache lock: Could not get lock /var/lib/dpkg/lock. It is held by process xxxx(dp…

【Docker】★★★

docker 的网络模式 ●host模式&#xff1a;使用 --nethost 指定 容器与宿主机共享网络命名空间、ip和端口 ●container模式&#xff1a;使用 --netcontainer:NAME_or_ID 指定 新建的容器共享已有容器的网络命名空间、ip和端口 ●none模式&#xff1a;使用 --netnone 指定 不进行…

阿里实习生:面试阿里其实并没有那么难。

愉快的五一假期已经结束了, 又要投入到学习和工作当中了。 今天分享一位同学在阿里的Go后端实习面经详解, 希望对你有帮助。 Go里有哪些数据结构是并发安全的&#xff1f; 并发安全就是程序在并发的情况下执行的结果都是正确的&#xff1b; Go中数据类型分为两大类&#xff…

24年最新抖音、视频号0成本挂机,单号每天收益上百,可无限挂

详情介绍 这次给大家带来5月份最新的短视频挂机项目&#xff0c;简单易上手&#xff0c;而且不需要任何投入&#xff0c;经过测试收益非常可观&#xff0c;软件完全免费&#xff0c;特别适合没有时间但是想做副业的家人们

ai生图什么软件好?推荐7个不错的AI绘画软件

ai生图什么软件好&#xff1f;推荐7个不错的AI绘画软件&#xff01;小编带你进入一个创意与科技交融的奇妙世界——AI绘画&#xff0c;让我们一同领略其中的魅力吧~ 一、爱制作AI 这款AI人工智能软件是一款多功能的工具平台&#xff0c;集合了AI问答、AI绘画和AI智能写作等功能…

在离线环境中将运行 Oracle DB 12c 的 CentOS 7.5 原地升级并迁移至 RHEL 7.9

《OpenShift / RHEL / DevSecOps 汇总目录》 说明 本文只是说明如何在 CentOS 7.5 上准备 Oracle DB 12c 验证环境&#xff0c;而将该环境升级并迁移至 RHEL 7.9 的操作过程请参见&#xff1a;《在离线环境中将 CentOS 7.5 原地升级并迁移至 RHEL 7.9》一文。 另外&#xff…