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即可

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Navicat for MySQL Mac:数据库管理与开发的理想工具

Navicat for MySQL Mac是一款功能强大的数据库管理与开发工具&#xff0c;专为Mac用户设计&#xff0c;旨在提供高效、便捷的数据库操作体验。 它支持创建、管理和维护MySQL和MariaDB数据库&#xff0c;通过直观的图形界面&#xff0c;用户可以轻松进行数据库连接、查询、编辑和…

第一批用AI绘画做设计的人,已经碾压同事了!

“上辈子作孽&#xff0c;这辈子作图。” 设计师的心累只有自己知道。熬夜肝图一个月&#xff0c;好不容易准时下班&#xff0c;饭刚送到嘴边&#xff0c;工作群消息开始疯狂轰炸&#xff0c;领导夺命连环催进度… 2年工作时间&#xff0c;等于别人工作了6年&#xff0c;疯狂加…

HTTP 多个版本

了解一下各个版本的HTTP。 上个世纪90年代初期&#xff0c;蒂姆伯纳斯-李&#xff08;Tim Berners-Lee&#xff09;及其 CERN的团队共同努力&#xff0c;制定了互联网的基础&#xff0c;定义了互联网的四个构建模块&#xff1a; 超文本文档格式&#xff08;HTML&#xff09; …

深度学习之基于Resnet50卷积神经网络脊柱骨折CT影像图片诊断系统

欢迎大家点赞、收藏、关注、评论啦 &#xff0c;由于篇幅有限&#xff0c;只展示了部分核心代码。 文章目录 一项目简介 二、功能三、系统四. 总结 一项目简介 一、项目背景 脊柱骨折是骨科中一种常见的损伤类型&#xff0c;准确的诊断对于患者的治疗和康复至关重要。传统的脊…

信创 | 2023年中国信创产业深度研究报告(完整版)

信创产业研究报告 免责声明&#xff1a;本文资料来源于“第一新声”&#xff0c;版权归原作者所有。如涉及作品版权问题&#xff0c;请与我们联系&#xff0c;我们将在第一时间协商版权问题或删除内容&#xff01; 获取文中相关的PPT资料&#xff0c;请关注文末公众号“程序员…

【Java EE】多线程(三)线程状态

&#x1f4da;博客主页&#xff1a;爱敲代码的小杨. ✨专栏&#xff1a;《Java SE语法》 | 《数据结构与算法》 | 《C生万物》 |《MySQL探索之旅》 |《Web世界探险家》 ❤️感谢大家点赞&#x1f44d;&#x1f3fb;收藏⭐评论✍&#x1f3fb;&#xff0c;您的三连就是我持续更…

Win10彻底关闭Antimalware Service Executable解决cpu内存占用过高问题

1&#xff0c;win键R打开运行输入gpedit.msc&#xff0c;即可打开本地组策略编辑器 2.依次打开&#xff1a;管理模板----windows组件----windows Defender-----实时保护 3.然后鼠标双击右侧的“不论何时启用实时保护&#xff0c;都会启用进程扫描。勾选 已禁用&#xff0c;就可…

EPSON的温补晶振TG7050SKN

EPSON公司推出的温补品振(TCXO)TG7050SKN&#xff0c;尺寸大小为7.0x5.0x1.5 mm&#xff0c;具有高稳定性(105℃℃高温)等特点&#xff0c;可输出10MHz~54MHz的频率可应用在网络同步&#xff0c;BTS&#xff0c;微波&#xff0c;以及需要符合Stratum3、SyncE和IEEE1588等规范的…

JVM笔记3-经典的垃圾收集器

上图展示了7种&#xff0c;适用于不同分代中的收集器。如果两者之间由连线&#xff0c;说明可以搭配使用。 PS&#xff1a;在JDK8中将SerialCMS和ParNewSerial Old的组合声明为废弃&#xff0c;并且在JDK9中完全取消了这两种组合的支持。 1、Serial收集器 Serial收集器是JVM中…

护士节趣味互动h5小游戏的作用是什么

护士节也同样气氛满满&#xff0c;护士总量非常高&#xff0c;针对此群体不少行业都可借势营销&#xff0c;为自己的生意及品牌赋能&#xff0c;奖品吸引用户参与&#xff0c;趣味形式及控件达成多种效果。 在【雨科】平台拥有多款护士节互动小游戏类型&#xff0c;页面元素/背…

5000亿参数来了:微软将推出 MAI-1 模型硬刚谷歌和OpenAI|TodayAI

美国的科技巨头微软公司&#xff0c;正在积极扩展其人工智能&#xff08;AI&#xff09;技术的领域。最新消息显示&#xff0c;微软将推出一款名为MAI-1的全新AI模型&#xff0c;其规模巨大&#xff0c;预计将拥有5000亿个可调参数。这一开发工作由Inflection AI的CEO穆斯塔法苏…

SpringBoot 扩展篇:ConfigFileApplicationListener源码解析

SpringBoot 扩展篇&#xff1a;ConfigFileApplicationListener源码解析 1.概述2. ConfigFileApplicationListener定义3. ConfigFileApplicationListener回调链路3.1 SpringApplication#run3.2 SpringApplication#prepareEnvironment3.3 配置environment 4. 环境准备事件 Config…

社交媒体数据恢复:抖音、火山版、极速版

抖音是一款非常受欢迎的短视频社交平台&#xff0c;在使用过程中&#xff0c;有时候我们会不小心删除了重要的聊天记录。那么&#xff0c;如何恢复抖音聊天记录呢&#xff1f;下面&#xff0c;我将为大家带来一份详细的抖音聊天记录数据恢复教程。 一、抖音聊天记录恢复方法 打…

Angular中组件之间的传值

Angular中组件之间的传值 文章目录 Angular中组件之间的传值前言一、父亲向儿子传值二、儿子向父亲传值三、爷爷向孙子传值四、兄弟之间的传值 前言 Angular的组件是构成应用的基础单元&#xff0c;它们封装了HTML模板、TypeScript代码以及CSS样式&#xff0c;以实现特定的功能…

【算法学习】day2

文章目录 BFS1.图像渲染2.岛屿数量 BFS 1.图像渲染 思路&#xff1a;BFS宽度遍历&#xff0c;我们需要对初始像素进行一层一层遍历&#xff0c;也就是上下左右四个方向进行遍历判断&#xff0c;如何访问这四个方向呢&#xff0c;就需要利用两个数组dx和dy来进行判断和遍历&…

【RPC】Dubbo接口测试

关于rpc&#xff0c;推荐看看这篇 &#xff1a; 既然有HTTP协议&#xff0c;为什么还要有RPC 一、Dubbo 是一款alibaba开源的高性能服务框架&#xff1a; 分布式服务框架高性能和透明化的RPC远程服务调用方案SOA服务治理方案 二、Dubbo基础架构 三、 Dubbo接口测试 1、jme…

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

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

并行执行的概念—— 《OceanBase 并行执行》系列 一

From 产品经理&#xff1a; 这是一份姗姗来迟的关于OceanBase并行执行的系统化产品文档。 自2019年起&#xff0c;并行执行功能已被许多客户应用于多种场景之中&#xff0c;其重要性日益凸显。然而&#xff0c;遗憾的是&#xff0c;我们始终未能提供一份详尽的用户使用文档&…

如何应对访问国外服务器缓慢的问题?SDWAN组网是性价比之选

访问国外服务器缓慢通常由以下原因造成&#xff1a; 1、政策限制&#xff1a;我国管理互联网&#xff0c;限制部分国外网站和服务器&#xff0c;以维护国家安全稳定。 2、技术障碍&#xff1a;国内与国际互联网的网络架构和协议存在差异&#xff0c;可能导致数据传输不兼容。 …

探索AI编程新纪元:从零开始的智能编程之旅

提示&#xff1a;Baidu Comate 智能编码助手是基于文心大模型&#xff0c;打造的新一代编码辅助工具 文章目录 前言AI编程概述&#xff1a;未来已来场景需求&#xff1a;从简单到复杂&#xff0c;无所不包体验步骤&#xff1a;我的AI编程初探试用感受&#xff1a;双刃剑下的深思…