select+管道

pengjianbokobe

1. $ cat pipe.c
   
2. #include <sys/select.h>
   
3. #include <pthread.h>
   
4. #include <unistd.h>
   
5. #include <stdio.h>
   
6. 
   
7. int fdctl[2];// 这个管道在建立线程之前建立。创建线程之后，两个线程各连接其中一端。因为不存在 fork 导致的 fd 复制，所以不需要像普通多进程环境一样 close 一端
   
8. 
   
9. // 控制线程，使用 fdctl[0]
   
10. void *thfun( void *arg )
    
11. {
    
12.   int i;
    
13.   for ( i = 0; i < 3; ++i )
    
14.     {
    
15.       printf( "%d sec\n", i );
    
16.       sleep( 1 );
    
17.     }
    
18. 
    
19.   close( fdctl[0] );// 当一个 fd 被关闭的时候，会触发 readable / writable 事件
    
20. }
    
21. 
    
22. // 主线程 select 阻塞
    
23. int main()
    
24. {
    
25.   fd_set rdset;
    
26.   int maxfd = 2;
    
27.   pipe( fdctl );
    
28.   maxfd = fdctl[1];
    
29.   FD_ZERO( &rdset );
    
30.   FD_SET( STDIN_FILENO, &rdset ); // 需要被监测的 fd，通常为 socket。这里用 stdin 代替
    
31.   FD_SET( fdctl[1], &rdset ); // 控制管道。虽然 close 管道一端会同时引发 readable / writable 事件，但是由于 pipe 有缓冲，默认情况下 pipe 就是 writable 的，所以使用 rdset 进行监测
    
32. 
    
33.   pthread_t tid;
    
34.   pthread_create( &tid, NULL, thfun, NULL );
    
35. 
    
36.   int res = select( maxfd + 1, &rdset, NULL, NULL, NULL ); // 同时监测 socket 和控制管道。writable set 也可以同时监测其它 fd
    
37.   printf( "select() returned with %d\n", res );
    
38.   if ( res == 1 ) {
    
39.     if ( FD_ISSET( fdctl[1], &rdset ) ) // 是否控制管道产生的事件？
    
40.       printf( "Ctrled Exit\n" ); // 如果是，则是由于控制线程触发。select 阻塞被成功打断
    
41.     else
    
42.       deal_with_fd(); // 不是控制管道的信息；处理来自 socket 的信息
    
43.   }
    
44.   return 0;
    
45. }

复制代码

这是一段加精的程序，原链接为：http://bbs.chinaunix.net/viewthr ... p;extra=&page=1
看不懂这样写的意义和用途，请指教，谢谢   

pengjianbokobe

up

lanying_wzw

利用管道这样的手段，统一处理多种事件，这些事件对象往往不是文件，比如消息队列等，这也是管道的常用技巧