Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1419920
  • 博文数量: 430
  • 博客积分: 9995
  • 博客等级: 中将
  • 技术积分: 4388
  • 用 户 组: 普通用户
  • 注册时间: 2006-05-24 18:04
文章存档

2013年(1)

2008年(2)

2007年(14)

2006年(413)

分类:

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 */

阅读(634) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~