分类:
2006-08-01 17:59:01
阻塞
阻塞,你也许早就听说了。"阻塞"是 "sleep" 的科技行话。你可能注意到前面运行的 listener 程序,他在那里不停地运行,等待数据包的到来。实际在运行的是 他调用 recvfrom(),然后没有数据,因此 recvfrom() 说"阻塞 (block)" 直到数据的到来。
很多函数都利用阻塞。accept() 阻塞,所有的 recv*() 函数阻塞。他们 之所以能这样做是因为他们被允许这样做。当你第一次调用 socket() 建立套接口 描述符的时候,内核就将他设置为阻塞。如果你不想套接口阻塞,你就要调用函数 fcntl():
#include
#include
.
.
sockfd = socket(AF_INET, SOCK_STREAM, 0);
fcntl(sockfd, F_SETFL, O_NONBLOCK);
.
.
通过设置套接口为非阻塞,你能够有效地"询问"套接口以获得信息。如果你尝试着 从一个非阻塞的套接口读信息并且没有任何数据,他不会变成阻塞--他将返回 -1 并 将 errno 设置为 EWOULDBLOCK。
但是一般说来,这种轮询不是个好主意。如果你让你的程序在忙等状态查询套接口的数据, 你将浪费大量的 CPU 时间。更好的解决之道是用下一章讲的 select() 去查询 是否有数据要读进来。
--------------------------------------------------------------------------------
select()--多路同步 I/O
虽然这个函数有点奇怪,但是他很有用。假设这样的情况:你是个服务器,你一边在不停地 从连接上读数据,一边在侦听连接上的信息。
没问题,你可能会说,不就是一个 accept() 和两个 recv() 吗? 这么容易 吗,朋友? 如果你在调用 accept() 的时候阻塞呢? 你怎么能够同时接受 recv() 数据? "用非阻塞的套接口啊!" 不行!你不想耗尽所有的 CPU,不是吗? 那么,该如何是好?
select() 让你可以同时监视多个套接口。如果你想知道的话,那么他就会告诉你哪个套接口准备读,哪个又 准备好了写,哪个套接口又发生了例外 (exception)。
闲话少说,下面是 select():
#include
#include
#include
int select(int numfds, fd_set *readfds, fd_set *writefds,
fd_set *exceptfds, struct timeval *timeout);
这个函数监视一系列文件描述符,特别是 readfds、writefds 和 exceptfds。如果你想知道你是否能够从标准输入和套接口描述符 sockfd 读 入数据,你只要将文件描述符 0 和 sockfd 加入到集合 readfds 中。 参数 numfds 应该等于最高的文件描述符的值加1。在这个例子中,你应该设置该值 为 sockfd+1。因为他一定大于标准输入的文件描述符 (0)。
当函数 select() 返回的时候,readfds 的值修改为反映你选择的哪个文件 描述符可以读。你可以用下面讲到的宏 FD_ISSET() 来测试。
在我们继续下去之前,让我来讲讲如何对这些集合进行操作。每个集合类型都是 fd_set。 下面有一些宏来对这个类型进行操作:
FD_ZERO(fd_set *set) - clears a file descriptor set
FD_SET(int fd, fd_set *set) - adds fd to the set
FD_CLR(int fd, fd_set *set) - removes fd from the set
FD_ISSET(int fd, fd_set *set) - tests to see if fd is in the set
最后,是有点古怪的数据结构 struct timeval。有时你可不想 永远等待别人发送数据过来。也许什么事情都没有发生的时候你也想每隔96秒在终端 上打印字符串 "Still Going..."。这个数据结构允许你设定一个时间,如果时间到了, 而 select() 还没有找到一个准备好的文件描述符,他将返回让你继续处理。
数据结构 struct timeval 是这样的:
struct timeval {
int tv_sec; /* seconds */