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

news2024/12/26 9:22:40

文章目录

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

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

无论是什么样的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.coloradmin.cn/o/1647876.html

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

相关文章

Redis教程——主从复制

在上篇文章我们学习了Redis教程——管道&#xff0c;这篇文章学习Redis教程——主从复制。 主从复制 为了数据更加安全可靠&#xff0c;在实际的项目中&#xff0c;肯定是有多个Redis服务&#xff0c;主机Redis以写为主&#xff0c;从机Redis以读为主&#xff0c;当主机Redis…

什么年代了,还在拿考勤说事

最近&#xff0c;看到了某公司的一项考勤规定&#xff1a;自然月内&#xff0c;事假累计超过3次或者累计请假时间超过8小时的&#xff0c;不予审批&#xff0c;强制休假的按旷工处理。 真的想吐槽&#xff0c;什么年代了&#xff0c;还在拿考勤说事&#xff0c;这是什么公司、什…

国内游戏公司Q1净利润大增40%以上,神州泰岳增幅65.62%

易采游戏网5月7日消息&#xff0c;近日多家国内知名游戏公司公布了其2024年第一季度的财务报告&#xff0c;其中净利润大增40%以上的数据引起了市场的广泛关注。这一业绩表现不仅远超市场预期&#xff0c;也再次证明了国内游戏行业的强劲增长势头。 据了解&#xff0c;这些游戏…

react【实用教程】 搭建开发环境(2024版)Vite+React (官方推荐)

以项目名 reactDemo为例 1. 下载脚手架 在目标文件夹中打开命令行 npm create vite2. 安装项目依赖 cd reactDemo npm i若安装失败&#xff0c;则修改下载源重试 npm config set registry https://registry.npmmirror.com3. 启动项目 npm run dev4. 预览项目 浏览器访问 http…

vue 百度地图点击marker修改marker图片,其他marker图片不变。

直接上代码 marker.name tag;marker.id i; //一定要设置id&#xff0c;我这里是设置的循环key值&#xff0c;要唯一性。map.addOverlay(marker);let pointAIcon2 new BMapGL.Icon(require("../xxxxx.png"), new BMapGL.Size(36, 52));let pointAIcon1 new BMapGL.I…

翔云优配官网美股市场分析问界回应M7事故四大疑问

问界再次新M7 Plus山西高速事故。 4月26日下午,山西运城曾有一辆问界新M7 Plus车辆(以下简称“事故车辆”)在高速行驶时和一辆高速洒水车追尾,碰撞后车辆起火,造成三人遇难,该事故引发了广泛关注。 翔云优配以其专业的服务和较低的管理费用在市场中受到不少关注。该平台提供了…

管理能力学习笔记九:授权的常见误区和如何有效授权

授权的常见误区 误区一&#xff1a;随意授权 管理者在授权工作时&#xff0c;需要依据下属的能力、经验、意愿问最自己&#xff1a;这项工作适合授权给Ta做吗&#xff1f;如果没有&#xff0c;可以通过哪些方法进行培训呢&#xff1f; 误区二&#xff1a;缺乏信任 心理暗示…

Photoshop中选区工具的应用

Photoshop中选区工具的应用 前言Photoshop中选区工具的基本操作创建选区的工具及方法选择、取消、隐藏选区选区的增加、减少选区的应用变换扩大选取与选取相似 Photoshop中采用快速选择工具来创建选区Photoshop中采用色彩范围命令来创建选区Photoshop中采用快速蒙版来创建选区P…

UV胶是什么材料制成的?

UV胶是一种特殊的胶水&#xff0c;由丙烯酸酯单体、活性稀释剂、光引发剂、助剂等材料制成的。它是指在紫外线照射下能够迅速固化的胶水。UV胶的主要成分是丙烯酸酯单体&#xff0c;它在没有紫外线照射时是液体状态&#xff0c;但一旦受到紫外线照射&#xff0c;就会迅速发生聚…

电脑如何查看一段时间内是否被人使用过?

前言 有时候我们可能会担心别人未经许可使用我们的电脑。为了确保自己不在场时电脑是否被使用过&#xff0c;以下两种方法可能会帮到你 第一种方法 WinX打开事件查看器。像WinX能快速打开很多东西&#xff0c;比如安装的应用(可以进行软件的删除)&#xff0c;设备管理器&…

生成requirements.txt文件

前言 对于Python项目&#xff0c;生成和使用requirements.txt是十分必要的。通过requirements.txt可以一次性保存和安装项目所需要的所有库。尤其是在复现github上的实验代码时。 方法1 常用的命令 pip freeze > requirements.txt然而这种方法并不好用&#xff0c;有时会…

影响项目成功的六个“致命”错误

项目经理作为项目的负责人&#xff0c;肩负着巨大的责任和挑战。他们需要具备专业知识、出色的综合管理能力以及敏锐的洞察力&#xff0c;以便在项目执行过程中及时关注项目动态&#xff0c;处理好各种问题&#xff0c;并避免那些可能影响项目实施的致命错误。 一、缺乏明确的…

社交媒体数据恢复:华为畅连

尊敬的用户您好&#xff0c;以下是关于社交软件华为畅连的聊天记录数据恢复教程。在华为手机中&#xff0c;我们可以通过华为云服务和第三方软件来恢复删除的聊天记录。以下是详细的步骤&#xff1a; 第一步&#xff1a;登录华为云服务 请在您的华为手机上找到并打开“云服务”…

Python实用记录(十六):PyQt/PySide6联动VSCode便捷操作指南

文章目录 一、安装vscode和配置pyside6环境二、安装vscode扩展三、扩展配置编辑四、编辑运行 一、安装vscode和配置pyside6环境 这一步默认已经通过了 二、安装vscode扩展 三、扩展配置编辑 四个地方需要修改&#xff1b;rcc路径、uic路径、designer.exe路径 uic.exe 用于将…

libcity笔记:libcity/utils/utils.py

1 get_logger 2 set_random_seed def set_random_seed(seed):"""重置随机数种子Args:seed(int): 种子数"""random.seed(seed)#设置 Python 内置的随机数生成器的种子np.random.seed(seed)#设置 NumPy 的随机数生成器的种torch.manual_seed(see…

三大国产中间件厂商

1、东方通 东方通:国产中间件整体市场领导者 1.1、概述 东方通是中国中间件的开拓者和领导者、国内大安全及行业信息化解决方案提供商。 以**“安全+”、“数据+”、“智慧+”** 三大产品体系为基础,为客户提供中间件、网络信息安全、行业数字化转型、智慧应急四大板块产品及…

【前端】HTML实现个人简历信息展示页面

文章目录 前言一、 综合案例&#xff1a;个人简历信息展示页面 前言 这篇博客仅仅是对HTML的基本结构进行了一些说明&#xff0c;关于HTML的更多讲解以及CSS、Javascript部分的讲解可以关注一下下面的专栏&#xff0c;会持续更新的。 链接&#xff1a; Web前端学习专栏 下面我…

【深度学习】实验1 波士顿房价预测

波士顿房价预测 代码 import numpy as np import matplotlib.pyplot as pltdef load_data():# 1.从文件导入数据datafile D:\Python\PythonProject\sklearn\housing.datadata np.fromfile(datafile, sep )# 每条数据包括14项&#xff0c;其中前面13项是影响因素&#xff0c…

企业微信hook接口协议,ipad协议http,客户群发送任务,获取要发送的客户群列表

客户群发送任务&#xff0c;获取要发送的客户群列表 参数名必选类型说明uuid是String每个实例的唯一标识&#xff0c;根据uuid操作具体企业微信 请求示例 {"uuid": "1688853790533324","id":1101292747044333637, //群发任务id"keyword…

Learning C# Programming with Unity 3D

作者&#xff1a;Alex Okita 源码地址&#xff1a;GitHub - badkangaroo/UnityProjects: A repo for all of the projects found in the book. 全书 686 页。