一，阻塞與非阻塞

1. char buf;  
2. fd=open("/dev/ttyS1",O_RDWR);  
3. ...  
4. res=read(fd,&buf,1);//當串列埠有輸入時才返回  
5. if(res==1)  
6.     printf("%c\n",buf);  

1. char buf;  
2. fd=open("/dev/ttyS1",O_RDWR|O_NONBLOCK);  //O_NONBLOCK設定為非阻塞方式
3. ...  
4. while(read(fd,&buf,1)!=1);//串列埠上無輸入也返回，所以要迴圈嘗試讀取串列埠  
5. printf("%c\n",buf); 
    

1. wait_queue_head_t my_queue;  

1. init_waitqueue_head(&my_queue);  

1. DECLARE_WAIT_QUEUE_HEAD (name);  

1. DECLARE_WAITQUEUE(name,tsk);定義並初始化一個名為name的等待佇列  

1. void fastcall add_wait_queue(wait_queue_head_t *q,wait_queue_t *wait);  
2. void fastcall remove_wait_queue(wait_queue_head_t *q,wait_queue_t *wait);  

等待事件 ：即程序的等待條件

休眠佇列

1. wait_event(queue,condition);等待以queue為等待佇列頭等待佇列被喚醒，condition必須滿足，否則阻塞  
2. wait_event_interruptible(queue,condition);可被訊號打斷  
3. wait_event_timeout(queue,condition,timeout);阻塞等待的超時時間，時間到了，不論condition是否滿足，都要返回  
4. wait_event_interruptible_timeout(queue,condition,timeout)  

1. void wake_up(wait_queue_head_t *queue);  
2. void wake_up_interruptible(wait_queue_head_t *queue);  

三，輪詢操作

1. int select(int numfds,fd_set *readfds,fd_set *writefds,fd_set *exceptfds,  
2.     struct timeval *timeout);  

功能：測試指定的fd可讀？可寫？有異常條件待處理？

readfds,writefds,exceptfds是被select監視的讀，寫，異常處理的檔案描述符集合。

1. struct timeval  
2. {  
3.     int tv_sec;  
4.     int tv_usec;  
5. };  

1. FD_ZERO(fd_set *set);//清除一個檔案描述符  
2. FD_SET(int fd,fd_set *set);//將一個檔案描述符加入檔案描述符集中  
3. FD_CLR(int fd,fd_set *set);//將一個檔案描述符從檔案描述符集中清除  
4. FD_ISSET(int fd,fd_set *set);//判斷檔案描述符是否被置位  

1. unsigned int (*poll)(struct file *filp, struct poll_table *wait);  

用於向poll_table註冊等待佇列的poll_wait()函式的原型

1. void poll_wait(struct file *filp,wait_queue_head_t *queue,poll_table *wait);  

1. static unsigned int xxx_poll(struct file *filp,poll_table *wait)  
2. {  
3.     unsigned int mask=0;  
4.     struct xxx_dev *dev=filp->private_data;  
5.     ...  
6.     poll_wait(filp,&dev->r_wait,wait);  
7.     poll_wait(filp,&dev->w_wait,wait);  
8.     if(read_buffer_not _empty)//可讀  
9.     {  
10.         mask|= POLLIN |POLLRDNORM;//資料可獲得  
11.     }  
12.     if(write_buffer_not _full)//可寫  
13.     {  
14.         mask|= POLLOUT|POLLWRNORM;//資料可寫入  
15.     }  
16.     ...  
17.     return mask;  
18. }  

1. eg4:globalfifo裝置驅動的poll()函式  

1. static unsigned int globalfifo_poll(struct file *filp,poll_table *wait)  
2. {  
3.     unsigned int mask=0;  
4.     struct globalfifo_dev *dev=filp->private_data;  
5.     down(&dev->sem);  
6.     poll_wait(filp,&dev->r_wait,wait);  
7.     poll_wait(filp,&dev->w_wait,wait);  
8.     //fifo非空  
9.     if(dev->current_len!=0)  
10.     {  
11.         mask|=POLLIN |POLLRDNORM;//標示資料可獲得    
12.     }  
13.     //fifo非滿  
14.     if(dev->current_len!=GLOBALFIFO_SIZE)  
15.     {  
16.         mask|=POLLOUT |POLLWRNORM;  
17.     }  
18.     up(&dev->sem);  
19.     return mask;  
20. }<

在測試程式中select()

main()
{
  int fd, num;
  char Buf[128]="memdev_poll test!";
  fd_set rfds,wfds;
 
  /*以非阻塞方式開啟/dev/memdev0裝置檔案*/
  fd = open("/dev/memdev0", O_RDWR | O_NONBLOCK);
  if (fd !=  - 1)
  {
    while (1)
        {
              FD_ZERO(&rfds);
              FD_ZERO(&wfds);
              FD_SET(fd, &rfds);
              FD_SET(fd, &wfds);

              select(fd + 1, &rfds, &wfds, NULL, NULL);
              /*資料可獲得*/
              if (FD_ISSET(fd, &rfds))
              {
                  printf("Poll monitor:can be read\n");
            lseek(fd, 0, SEEK_SET);
            read(fd, Buf, sizeof(Buf));
            printf("Read Buf: %s\n", Buf);
            sleep(1);
              }
              /*資料可寫入*/
              if (FD_ISSET(fd, &wfds))
              {
                  printf("Poll monitor:can be written\n");
            lseek(fd, 0, SEEK_SET);
            write(fd, Buf, sizeof(Buf));
            printf("Write Buf: %s\n", Buf);
            sleep(1);
              }      
       }
  }
  else
  {
    printf("Device open failure\n");
  }
}