3.7 非阻塞I/O
前面几节已介绍了完成各种I/O的系统调用,如read()、write()、open()等,这些系统调用在默认情形下均是阻塞的,也就是说,调用必须等待操作完成,即读写到数据,才能返回。但在有些应用中往往还有需要非阻塞I/O的情形。本节我们讨论使得这些调用成为非阻塞的方法。
UNIX系统调用根据阻塞还是非阻塞分为两类:一类是所谓的“慢”系统调用,其他的则归为另一类。慢系统调用是以下有可能被永久阻塞的调用:
调用read()读管道、终端设备或网络设备文件时,如果数据不出现则可能永久阻塞调用者;调用write()写同样的文件,如果数据不能立即被接收也可能永久阻塞调用者。
打开一个文件将阻塞直至出现某种条件。例如,打开一个终端设备将等待相连的调制解调器回应;打开一个只写的FIFO,但没有其他进程打开它用于读。
读写一个具有强制锁(10.1节)的文件。
某些ioctl()操作。
某些进程间通信函数(参见第11章)。
默认情况下,关于I/O的系统调用总是阻塞的,调用必须等待操作完成,即读写到数据才能返回。但是慢系统调用并不包括所有阻塞I/O,这里包括的只是可能永久阻塞的系统调用。例如,磁盘I/O有关的系统调用就不是慢系统调用,尽管读写磁盘文件也可能临时阻塞调用者。
非阻塞I/O可以使得I/O操作如open()、read()或write()不会被永久阻塞,如果操作不能完成,这些调用将立即返回并给出错误码指明操作可能被阻塞。
对于给定的文件描述字,有两种方法指定非阻塞I/O:
1)在open()时指定O_NONBLOCK文件状态标志。
2)对已经打开的描述字,调用fcntl()函数设置O_NONBLOCK文件状态标志。
例3-7 在非阻塞I/O情况下传输数据,当读写不能立即完成时会返回–1并置errno为EAGAIN。这时,往往需要再次调用read()或write()。我们来看一个非阻塞I/O的程序例子,这个例子使用了程序3-6给出的函数set_nonblock_flag()来设置和清除O_NONBLOCK标志。
程序3-7 非阻塞I/O之例
#include "ch03.h"
#include "p3-6.c"
#define B_SIZE 100000
char buf[B_SIZE];
char fmt[] = "%d Hi :( -> :) ---aha!---";
int main(void)
{
int nbytes=0, j=0, nwrite, ntimes = 1, success=0;
char *ptr;
if(set_nonblock_flag(STDOUT_FILENO, 1) < 0) /* 设置无阻塞I/O */
err_exit("set nonblock flag failed ");
while (nbytes+sizeof(fmt) < B_SIZE) {
sprintf(&buf[nbytes],fmt,j++);
nbytes += sizeof(fmt);
}
/* 将buf中的数据写至标准输出,直至全部写出 */
for(ptr=buf; nbytes >0; ntimes++){
errno = 0;
nwrite = write(STDOUT_FILENO, ptr, nbytes);
if(nwrite < 0){
fprintf(stderr,"\n%d nwrite=%d, error=%d ",ntimes,nwrite,errno);
perror("");
} else {
fprintf(stderr,"\n%d nwrite=%d, error=%d ",ntimes,nwrite,errno);
ptr += nwrite;
success++;
nbytes -= nwrite;
}
}
printf("success=%d\n",success);
exit(0);
}
程序3-7以非阻塞方式将buf中的数据全部写到标准输出文件。因为是非阻塞方式,write()操作有可能由于阻塞而没有完成或者只写了一部分数据就返回。为了保证buf中的数据全部写至标准输出文件,我们将write()放置在一个循环内,并以写完nbytes字节作为循环终止条件。
执行这个程序时,若标准输出文件是磁盘文件,则只需一次write()便可写出全部数据:
%a.out>file
1 nwrite=99996, error=0
%ls 杔 file
-rw-r--r-- 1 zkj zkj 99996 Jun 22 21:15 l
但是,若标准输出文件是终端,则会多次调用write(),其中有一些写出部分数据,有一些则返回错误。这是因为当执行下一个write()时,终端还来不及显示完前面输出的数据而以EAGIN错误返回。
%a.out 2>output
... 显示大量写出的内容
--3702 Hi :( -> :) ---aha!---success=43
%cat output
1 nwrite=4095, error=0
2 nwrite=4095, error=0
3 nwrite=2048, error=0
4 nwrite=-1, error=11 Resource temporarily unavailable
5 nwrite=4095, error=0
6 nwrite=-1, error=11 Resource temporarily unavailable
7 nwrite=2048, error=0
... 省略的输出
20 nwrite=2048, error=0
21 nwrite=-1, error=11 Resource temporarily unavailable
22 nwrite=2048, error=0
... 省略的输出
78 nwrite=1695, error=0
76 nwrite=-1, error=11 Resource temporarily unavailable
77 nwrite=-1, error=11 Resource temporarily unavailable
78 nwrite=1695, error=0
这次运行过程中调用了78次write(),其中只有43次成功写出了数据,其余为错误返回,错误码为11,代表资源暂时不能满足导致操作受阻。由于程序使用了循环在所写出的字节数不满足时反复调用write(),从而使得buf中的内容最终被全部写出。
程序3-7的这类循环称为“轮询”,它存在两个问题:在多用户系统中它浪费了不少CPU时间,本来这些用于等待的CPU时间可以做其他事情或者让给其他进程。另外,它仍然没有避免永久阻塞的问题,虽然write()能立即返回,但它可能由于总是不能写出数据而导致出现死循环。为了避免死循环,我们必须设置一定的时间限制,以便时间到时能跳出循环。在10.3节介绍多路I/O时,我们可以看到解决这个问题更有效的方法。