一、poll()函數(shù)解析

不同與select使?用三個位圖來表?示三個fdset的?方式，poll使?用?一個 pollfd的指針實現(xiàn)。pollfd結(jié)構(gòu)包含了要監(jiān)視的event和發(fā)?生的event，??

不再使?用select“參數(shù)-值”傳遞的?方式。同時，pollfd并沒有最?大數(shù)量限制（但是數(shù)量過?大后性能也是會下降）。 和select函數(shù)?一樣，

?poll返回后，需要輪詢pollfd來獲取就緒的描述符。

?

poll()函數(shù)：這個函數(shù)是某些Unix系統(tǒng)提供的用于執(zhí)行與select()函數(shù)同等功能的函數(shù)，下面是這個函數(shù)的聲明： #include <poll.h> int poll(struct pollfd fds[], nfds_t nfds, int timeout)； 參數(shù)說明: struct pollfd：

　　struct pollfd{

　　int fd;????????????? //文件描述符

　　short events;??? //等待的事件

　　short revents;?? //實際發(fā)生的的事件

　　};

　　

events和revents是通過對代表各種事件的標志進行邏輯或運算構(gòu)建而成的。events包括要監(jiān)視的事件，

?poll用已經(jīng)發(fā)生的事件填充revents。poll函數(shù)通過在revents中設(shè)置標志字符POLLHUP、POLLERR、POLLNVAL等來反映相關(guān) ? ? ? ? 條件的存在。

不需要在events中對于這些標志符相關(guān)的比特位進行設(shè)置。如果fd小于0， 則events字段被忽略，而revents被置為0.

標準中沒有說明如何處理文件結(jié)束。文件結(jié)束可以通過revents的標識符POLLHUP或返回0字節(jié)的常規(guī)讀操作來傳達。

即使POLLIN或POLLRDNORM指出還有數(shù)據(jù)要讀，POLLHUP也可能會被設(shè)置。因此，應(yīng)該在錯誤檢驗之前處理正常的讀操作。

poll函數(shù)的事件標志符值:

常量	說明
POLLIN	普通或優(yōu)先 帶數(shù)據(jù)可讀
POLLRDNORM ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ??	普通數(shù)據(jù)可讀
POLLRDBAND	優(yōu)先級帶數(shù)據(jù) ? ? ? 可讀
POLLPRI	高優(yōu)先級數(shù)據(jù) ? ? ? 可讀
POLLOUT	普通數(shù)據(jù)可寫
POLLWRNORM	普通數(shù)據(jù)可寫
POLLWRBAND	優(yōu)先級帶數(shù)據(jù) ? ? ? 可寫
POLLERR	發(fā)生錯誤
POLLHUP	發(fā)生掛起
POLLNVAL	描述字不是一 個打開的文件

注：后三個只能作為描述字的返回結(jié)果存儲在revents中，而不能作為測試條件用于events中。

? ? ??fds：是一個struct pollfd結(jié)構(gòu)類型的數(shù)組，用于存放需要檢測其狀態(tài)的Socket描述符；每當調(diào)用這個函數(shù)之后，系統(tǒng)不會清空這個數(shù)組，操作起來比較方便；特別是對于socket連接比較多的情況下，在一定程度上可以提高處理的效率；這一點與select()函數(shù)不同，調(diào)用select()函數(shù)之后，select()函數(shù)會清空它所檢測的socket描述符集合，導致每次調(diào)用select()之前都必須把socket描述符重新加入到待檢測的集合中；因此，select()函數(shù)適合于只檢測一個socket描述符的情況，而poll()函數(shù)適合于大量socket描述符的情況； nfds：nfds_t類型的參數(shù)，用于標記數(shù)組fds中的結(jié)構(gòu)體元素的總數(shù)量； timeout：是poll函數(shù)調(diào)用阻塞的時間，單位：毫秒；
返回值:

> 0 ：數(shù)組fds中準備好讀、寫或出錯狀態(tài)的那些socket描述符的總數(shù)量；

== 0 ：數(shù)組fds中沒有任何socket描述符準備好讀、寫，或出錯；此時poll超時，超時時間是timeout毫秒；換句話說，如果所檢測的socket描述符上沒有任何事件發(fā)生的話，那么poll()函數(shù)會阻塞timeout所指定的毫秒時間長度之后返回，如果timeout==0，那么poll() 函數(shù)立 即返回而不阻塞，如果timeout==INFTIM，那么poll() 函數(shù)會一直阻塞下去，直到所檢測的socket描述符上的感興趣的事件發(fā)生是才返回，如果感興趣的事件永遠不發(fā)生，那么poll()就會永遠阻塞下去；

? ?== -1 ： poll函數(shù)調(diào)用失敗，同時會自動設(shè)置全局變量errno；
二、poll應(yīng)用實例 實例一：用poll監(jiān)視輸入輸出 #include<stdio.h> #include<poll.h> #include<stdlib.h> #include<string.h> int main(int argc,char *argv[]) {struct pollfd _poll[1];_poll[0].fd=0;_poll[0].events=POLLIN;_poll[0].revents=0;int timeout=3000;int i=0;char buf[1024]; while(1) {switch(poll(_poll,1,timeout)){case 0:printf("timeout");break;case -1:printf("poll");break;default:{for(i=0;i<2;i++){if((_poll[0].fd==0)&&(_poll[0].revents)&POLLIN){ssize_t s=read(0,buf,sizeof(buf)-1);if(s>0){buf[s]=0;if(strncmp(buf,"hello poll",10)==0){close(_poll[i].fd);return 1;}printf("this is test:poll:%s\n",buf);}}}}break;} } return 0; }

事例二：poll實現(xiàn)服務(wù)器端：

#include<stdio.h> #include<stdlib.h> #include<poll.h> #include<unistd.h> #include<sys/types.h> #include<sys/socket.h> #include<arpa/inet.h> #include<netinet/in.h> #include<string.h> static void usage(char *proc) {printf("usage:%s [local_ip] [local_port]\n",proc); } int startup(char* _ip,int _port) {//create socketint sock=socket(AF_INET,SOCK_STREAM,0);if(sock<0){perror("socket");return 2;}//port multiplexingint flg=1; setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,&flg,sizeof(flg));struct sockaddr_in local;local.sin_family=AF_INET;local.sin_addr.s_addr=inet_addr(_ip);local.sin_port=htons(_port);//bindif(bind(sock,(struct sockaddr*)&local,sizeof(local))<0){perror("bind");return 3;}//listenif(listen(sock,10)<0){perror("listen");return 4;}return sock; } int main(int argc,char *argv[]) {if(argc!=3){usage(argv[0]);return 1;}int listen_sock=startup(argv[1],atoi(argv[2]));struct pollfd fd_set[2];fd_set[0].fd=listen_sock;fd_set[0].events=POLLIN;fd_set[0].revents=0;int timeout=2000;int n=sizeof(fd_set)/sizeof(fd_set[0]);struct sockaddr_in client;socklen_t len=sizeof(client);int i=1;for(;i<n;i++){fd_set[i].fd=-1;}int maxfd=0;while(1){switch(poll(fd_set,maxfd+1,timeout)){case 0:printf("timeout..\n");break;case -1:printf("poll");break;default:{for(i=0;i<n;i++){if((fd_set[i].fd==listen_sock)&& \(fd_set[i].revents)&POLLIN){int new_sock=accept(listen_sock,\(struct sockaddr*)&client,&len);if(new_sock<0){perror("accept");continue;}printf("get a new client:\n");int j=0;for(j=0;j<n;j++){if(fd_set[j].fd==-1){fd_set[j].fd=new_sock;fd_set[j].events=POLLIN;fd_set[j].revents=0;break;}} if(j==n){close(new_sock);}if(j>maxfd){maxfd=j;}}else if((fd_set[i].fd>0)&& (fd_set[i].revents)&POLLIN){char buf[1024];ssize_t s=read(fd_set[i].fd,buf,sizeof(buf)-1);if(s>0){buf[s]='\0';printf("client: %s\n",buf);write(fd_set[i].fd,buf,strlen(buf));}else if(s==0){close(fd_set[i].fd);int p=1;for(;p<n;i++){if((fd_set[p].fd!=-1)&&(p!=i)){int temp=fd_set[i].fd;fd_set[i].fd=fd_set[p].fd;fd_set[p].fd=temp;}}}}}}break;}}return 0; }

三、總結(jié) 1、poll的優(yōu)點 1）poll() 在應(yīng)付大數(shù)目的文件描述符的時候相比于select速度更快，相對于select更加高效。 2）解決了select處理文件描述符有上限（默認1024）的限制。 2、poll缺點 1）、大量的fd的數(shù)組被整體復(fù)制于用戶態(tài)和內(nèi)核地址空間之間，而不管這樣的復(fù)制是不是有意義。? 2）、與select一樣，poll返回后，需要輪詢pollfd來獲取就緒的描述符 ?3）、事實上，同時連接的?大量客戶端在?一時刻可能只有很少的處于就緒狀態(tài)，因此隨著監(jiān)視的描述符數(shù)量的增長，其效率也會線性下降。

總結(jié)

以上是生活随笔為你收集整理的Linux: I/O多路转接之poll（有图有代码有真相！！！）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。