电子产业一站式赋能平台

PCB联盟网

搜索
查看: 36|回复: 0
收起左侧

嵌入式Linux:异步I/O

[复制链接]

1001

主题

1001

帖子

8805

积分

高级会员

Rank: 5Rank: 5

积分
8805
发表于 2025-3-28 08:01:00 | 显示全部楼层 |阅读模式

o2yzhutncmb6404873137.gif

o2yzhutncmb6404873137.gif

+ y0 U7 Q' X# L! V0 l2 m$ x点击上方蓝色字体,关注我们
" c" }& y- o9 Y6 q. C2 {6 R" L2 q/ b  b  w4 s- b
与I/O多路复用机制(如select和poll)相比,异步I/O通过信号通知机制,使得进程不需要反复查询I/O状态,而是由内核主动向进程发送信号(如SIGIO)来通知I/O状态的变化。% K( m/ m, {$ W6 z
1
& s; q8 Z  V. S8 D# A! u6 q! XI/O多路复用与异步I/O的区别
* C% z5 O% t) i6 o: UI/O多路复用(select/poll/epoll)
+ J8 R# _: y5 Y7 |" y  ^在多路复用机制中,进程使用select、poll或epoll等系统调用来主动查询文件描述符的状态,即等待某个文件描述符变得可读或可写。. G: `! C4 y" x% w+ `. o
$ i5 q% G5 J/ z" K9 X, l
这些方法虽然能有效处理多个文件描述符的事件,但本质上仍属于同步I/O,因为进程在发起查询时会被阻塞。- p" A) |% n) [$ T6 {, `
$ ?7 Y0 i7 J* [) Y* Q
异步I/O(Asynchronous I/O)2 Y6 X. o) d; V' v6 k) l& H, p
在异步I/O中,进程通过注册信号处理函数和设置文件描述符的异步标志,当I/O操作就绪时,内核会自动向进程发送信号(通常是SIGIO信号),不再需要主动轮询状态。
3 z; j3 l$ {8 A+ R6 S  j5 M* A8 `0 v( H8 B( l3 Y: K$ z
进程在等待I/O时可以继续执行其他任务,收到信号后再执行相应的I/O操作。
. S7 x3 ]9 k0 z) x6 k27 j* a& `+ [9 H2 e
实现异步I/O的步骤. y  N( z$ z9 N3 H0 h$ A- V7 f
在Linux中,使用异步I/O通常需要配合信号机制。# w' Y7 c8 v8 I* |, _

" \2 L1 S6 D, Z' K# S* U: F具体步骤如下:& \6 z7 F7 p) ~
  • 设置文件描述符为非阻塞模式
  • 设置文件描述符的异步标志
  • 指定异步I/O事件的接收进程( K+ `( |( |% r4 x. s0 s
  • 为SIGIO信号注册信号处理函数, d- N) c  C3 e% j6 x3 H
    ' R6 q3 _. t# ^7 F' ?6 \$ h
    2.1、设置非阻塞模式+ U7 t% E8 f$ z! f; R3 G
    首先,需要将文件描述符设置为非阻塞模式(O_NONBLOCK标志),以便在执行I/O操作时不会阻塞当前进程。9 K9 b) \% W$ |- }$ O
    % m" r7 {3 x: q: K4 K6 u9 |0 x3 V: T! k
    可以通过fcntl系统调用来实现:- C) }7 _4 k, ^4 F
    - [3 f; m! {, x6 E! q
  • int fd = open("example.txt", O_RDWR | O_NONBLOCK);if (fd 0) {    perror("open");    return -1;}2.2、设置异步I/O标志(O_ASYNC)
    % S4 Q8 j" L$ l! T7 D' O6 a接下来,需要为文件描述符设置异步I/O标志(O_ASYNC)。该标志用于通知内核,当文件描述符上的I/O操作就绪时向接收进程发送SIGIO信号。. z% c  B! A. z
    ) H& e" Y  t# c3 g; o5 ^
    需要使用fcntl系统调用来完成此操作:
    - i: Y: l% F- a0 Z' O! h; Z. _
    + U4 y8 r% K0 L7 H9 F
  • int flags = fcntl(fd, F_GETFL);  // 获取当前标志flags |= O_ASYNC;                 // 增加O_ASYNC标志fcntl(fd, F_SETFL, flags);        // 设置新的标志注意:open函数无法直接通过指定O_ASYNC标志来使能异步I/O,因此必须通过fcntl来设置。
    6 i' l/ X% Y1 E( p0 m4 _0 n0 q) F) |7 ?! P0 A- z5 O$ L: ]3 y
    2.3、设置异步I/O事件的接收进程
    + G3 x0 d% c1 H% y默认情况下,异步I/O事件的接收进程是创建文件描述符的进程。
    6 `. u' u% c/ ]3 Q  [8 n4 |
    ) t# t( K, U& f但如果需要将I/O事件转交给其他进程,可以使用fcntl函数设置文件描述符的“所有者”,也就是指定哪个进程应当接收I/O事件的通知信号:. E! e# A) {+ Q: F$ K5 G3 l

    $ t9 ~0 Z2 E  a3 W% J, ?  u
  • fcntl(fd, F_SETOWN, getpid()); // 设置当前进程为异步I/O事件的接收进程2.4、注册SIGIO信号处理函数
    ! C, ?4 Y4 B7 Q7 m1 c最后,为SIGIO信号注册信号处理函数。可以使用signal或sigaction函数为SIGIO信号注册一个处理函数。
    % V* u! `% @$ Z; P; m# U, _* r# o8 [4 B: e
    当文件描述符上有I/O操作就绪时,内核会向接收进程发送SIGIO信号,触发信号处理函数的执行。4 |, n+ `. s5 K# x4 {$ t* a4 E9 O2 I2 X
    + M; c2 _$ L7 z+ A
    以下是信号处理函数的注册示例:' R) A: M: F+ e* ~) c  ?
    - x* v; H& _# j; ~* `# {
  • void sigio_handler(int signum) {    // 执行I/O操作    char buffer[1024];    ssize_t bytes_read = read(fd, buffer, sizeof(buffer));    if (bytes_read > 0) {        buffer[bytes_read] = '\0';        printf("异步读取的数据:%s
    8 h; ]# R- M+ V  L0 ]( a. T", buffer);    }}5 ^1 H; \- E# z' f$ Q3 [) r: m
    int main() {    // 注册SIGIO信号处理函数    signal(SIGIO, sigio_handler);    // 设置文件描述符的非阻塞模式和异步模式    int fd = open("example.txt", O_RDWR | O_NONBLOCK);    if (fd 0) {        perror("open");        return 1;    }    // 使能异步I/O    int flags = fcntl(fd, F_GETFL);    flags |= O_ASYNC;    fcntl(fd, F_SETFL, flags);    // 设置异步I/O事件的接收进程    fcntl(fd, F_SETOWN, getpid());    // 主程序可以执行其他任务    while (1) {        printf("主进程在执行其他任务...
    ) B7 N- g0 Y! ]");        sleep(1);    }    close(fd);    return 0;}说明
    1 Z" m! T0 g- D) X: U: T
  • 在sigio_handler函数中,read函数用于读取文件描述符上的数据。
  • 主程序中,进程可以继续执行其他任务而不会被阻塞,当I/O操作就绪时,会自动触发SIGIO信号并调用信号处理函数。
    $ O: q  w, @+ X/ P- m' B5 @+ |; u' ~

    ; ^. S+ l" A3 n  t& u' `3
    ) X% Q6 V2 \8 N- pO_ASYNC标志的作用和注意事项! ?  c# E$ U8 b4 |) C+ f
    O_ASYNC标志用于使能文件描述符的异步I/O事件,使文件描述符在可执行I/O操作时向指定进程发送SIGIO信号。
    9 U6 b, _3 I) r9 a$ j7 w  O' b: j3 B9 s# [; K; c
    需要注意以下几点:& u$ v2 {5 [- f5 y* {# s7 c' a
  • 无法通过open直接设置O_ASYNC。必须使用fcntl设置文件描述符的异步标志。
  • 异步I/O事件的接收进程必须是文件描述符的所有者,如果需要其他进程接收SIGIO信号,必须通过F_SETOWN指定进程ID。
  • 信号处理函数的安全性:信号处理函数需要快速、简洁,不应调用阻塞的I/O操作或复杂的逻辑,否则可能影响主程序的实时性。
    ( }  }, B/ R+ U" T! q48 z% F6 _# n, S! u
    异步I/O的应用场景
  • 网络编程:在服务器端需要处理大量连接时,异步I/O可以避免进程阻塞,适合高并发应用场景。
  • 串口通信:在嵌入式系统中,串口通信是一种常见的通信方式。通过异步I/O,进程可以同时执行其他任务,不会因为串口I/O而阻塞。
  • 传感器数据采集:在实时数据采集系统中,异步I/O可以确保数据采集的实时性,进程在等待数据就绪时可以继续执行其他任务,提升CPU利用率。[/ol]9 h( w7 B1 Q  O3 M: v) ?6 }6 T# m# \
    57 c6 E1 `7 J0 P
    异步I/O的缺陷与优化) E7 B" ^1 X' Y/ D' R
    默认异步I/O信号SIGIO的局限
    * ^( I' k  [, m1 ?: J默认情况下,异步I/O使用非实时信号SIGIO作为通知信号。由于SIGIO是非实时信号,不支持信号排队机制,可能导致多个通知丢失。* f5 Z: |/ H  k

    ) s1 z0 Y8 c: u5 {$ Q) R4 P例如:
    3 C- e( z/ Z. A& _" ?
  • 当信号处理函数正在处理一个SIGIO信号时,后续的SIGIO信号可能被阻塞或忽略。
  • SIGIO信号只能在信号处理函数执行完毕后再次触发,而其中一些信号通知会丢失。9 X$ h+ E# i2 O' L5 r
    6 w: v) V- Y2 [7 k" T$ i
    这种缺陷会导致进程无法及时响应I/O事件,影响应用程序的实时性。+ o7 h8 t% o4 S! v3 S
    0 U( G) }( d1 }& w" V; m# T  E
    无法得知具体的事件类型
    - {' G9 d2 j( w  E2 P- U在默认的异步I/O信号处理函数中,进程无法直接获取文件描述符上具体的事件类型(如可读、可写、错误等),通常只能盲目地尝试执行I/O操作。$ \0 V, H0 e5 _- h1 p

    , j- x6 b- ~% T+ g为此,我们可以利用实时信号来提供更精确的事件信息,并通过结构体siginfo_t的扩展字段来识别事件类型。' ?  a& h$ D; v7 L; Q
    6
    # u. m# m3 ^# {9 g, X( L优化方法:使用实时信号替换默认信号
    6 J7 S8 |8 d) }* w通过将SIGIO替换为实时信号(如SIGRTMIN),可以实现信号的排队机制,从而确保多次I/O事件通知不会被丢失。步骤如下:
    3 \% o' O: y: @% ?; o$ b+ }& }5 s
    $ d6 V4 [1 T8 {0 ]" x; _) H6.1、设置实时信号作为异步I/O通知信号7 {  y' W) a$ R2 g' ~
    使用fcntl函数的F_SETSIG命令,将实时信号(如SIGRTMIN)替换默认信号SIGIO:# R) n, [) `" b5 S4 W

    5 d5 \" R# p$ b6 ^3 h. W1 f
  • fcntl(fd, F_SETSIG, SIGRTMIN); // 将SIGRTMIN设为fd的异步I/O通知信号如果参数设置为0,则将恢复为默认的SIGIO信号。( f4 ^  x3 D# Z* x

    7 n; h# _* W2 A6.2、使用sigaction注册信号处理函数
    6 n+ ]' z' g6 d使用sigaction函数替代signal函数,以便支持更高级的信号处理方式。2 i( D9 t' N! t4 C; X

    4 C; J. I9 z9 a, J% S9 |5 s通过为sa_flags设置SA_SIGINFO标志,我们可以在信号处理函数中使用扩展参数siginfo_t来获取更多事件信息:
    2 A6 L# |5 l) g, V7 P% y: ?- a$ j. m
  • void sigio_handler(int signo, siginfo_t *info, void *context) {    if (info->si_signo == SIGRTMIN) {   // 确认信号是SIGRTMIN        int fd = info->si_fd;            // 获取发生事件的文件描述符        int event = info->si_code;       // 获取事件类型        // 根据事件类型进行不同的处理        if (event == POLL_IN) {          // 可读取数据            // 执行读操作        } else if (event == POLL_OUT) {  // 可写入数据            // 执行写操作        } else if (event == POLL_ERR) {  // I/O错误            // 错误处理        }    }}int main() {    struct sigaction sa;    sa.sa_flags = SA_SIGINFO;            // 使用sa_sigaction处理函数    sa.sa_sigaction = sigio_handler;     // 注册信号处理函数    sigaction(SIGRTMIN, &sa, NULL);      // 绑定SIGRTMIN信号    // 设置文件描述符的异步I/O标志    int fd = open("example.txt", O_RDWR | O_NONBLOCK);    int flags = fcntl(fd, F_GETFL);    flags |= O_ASYNC;    fcntl(fd, F_SETFL, flags);    // 设置异步I/O事件的接收进程及信号    fcntl(fd, F_SETOWN, getpid());    fcntl(fd, F_SETSIG, SIGRTMIN);      // 指定实时信号SIGRTMIN    // 主程序继续执行    while (1) {        sleep(1);    }    close(fd);    return 0;}6.3、利用siginfo_t的扩展字段获取事件详情
    9 z. k( u( A# A) W在实时信号的信号处理函数中,siginfo_t结构体的si_code和si_band字段可以帮助识别发生的事件类型,如下:
    % l4 R& A7 \. F- A/ ?0 ]
  • si_fd:发生事件的文件描述符。
  • si_code:事件类型(如POLL_IN、POLL_OUT等),通过该字段可以确认文件描述符的状态。
  • si_band:事件的位掩码,与poll()函数的revents字段一致,用于进一步确认事件细节。4 F$ {6 E) `  J  O8 @+ O
    例如:9 \: B4 \4 Q# k3 Z3 R; {' q
    9 ^+ _7 @! J% X9 b2 y) r

    2uqrpadzqbp6404873237.png

    2uqrpadzqbp6404873237.png

    ; g) k% B  U- g通过这些扩展字段,可以在信号处理函数中更灵活地执行不同的I/O操作,避免盲目调用read或write操作,从而进一步提升性能和可靠性。
    / \! G# i+ r: Y9 @" Z/ Q
    2 n8 M# l1 v2 b/ H% P) s: r通过实时信号优化异步I/O,可以有效解决通知丢失及事件类型不足的问题,使异步I/O在文件描述符多且并发高的场景下性能更加稳定和可靠。( t, U( r# a5 @

    + i6 g. Q1 Y, k# W0 a9 {/ n配合siginfo_t的扩展信息,信号处理函数可以更加精准地响应I/O事件。
    , t- h+ ]" b% m! B" D7 f2 J# d* P1 ?) i5 ?
    在应用开发中,可以根据文件描述符的数量、实时性要求、CPU资源占用等因素,综合考虑使用异步I/O或epoll来构建高效的I/O处理框架。
    5 J* h" u6 f# Y

    heuaoeccqic6404873337.jpg

    heuaoeccqic6404873337.jpg
    - c8 {) `  b% H+ K

    pufoxb4rmhg6404873437.gif

    pufoxb4rmhg6404873437.gif

    9 {' |  {2 _. T( W点击阅读原文,更精彩~
  • 回复

    使用道具 举报

    发表回复

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则


    联系客服 关注微信 下载APP 返回顶部 返回列表