enpoll 和select模型的区别

poll英 [pu0259u028al]　美 [pou028al]　第三人称单数：polls第三人称复数：polls现在分词：polling过去分词：polled过去式：polledpoll 基本解释名词民意调查; 投票选举; 投票数; 头部及物动词得到（一定数目的）选票; 对…进行调查; 修剪; 修剪不及物动词投票; 作民意调查

poll意思如下：poll是一个英语单词，名词、及物动词、不及物动词、形容词，作名词时意为“投票；民意测验；投票数；投票所；（Poll）人名；（德、匈、罗、英）波尔”。作及物动词时意为“投票；剪短；对…进行民意测验；获得选票”，作不及物动词时意为“投票”，作形容词时意为“无角的；剪过毛的；修过枝的”。短语搭配1、Snap Poll.即席调查。2、straw poll.测验民意的投票；假投票；测验民意的假投票；民意调查。3、the poll.投票站。4、poll station.投票站。5、parallel poll.平行轮询。双语例句1、Have you ever done a poll or anything like that?你曾经做过什么民调或类似的活动吗？2、I don"t think we have to win the straw poll but we do have to show some progress.我不认为我们必须在这项草根性投票中获胜，但是我们必须表现出某些进展。3、But with that rise in poll standing it is likely he will get media scrutiny and then we will see whether that helps him or hurts him.可是，随着在民调中的排名上升，他很可能会受到媒体的详细审查，然后，我们将会看到这将会帮助他还是伤害他。

poll是基于链表存储。poll机制监测的文件句柄数没有限制，不同于select（一般监测数量1024，可以通过cat /proc/sys/fs/file_max查看），poll是基于链表存储的。poll是Linux中的字符设备驱动中的一个函数。Linux 2.5.44版本后，poll被epoll取代。和select实现的功能差不多，poll的作用是把当前的文件指针挂到等待队列。poll本质上和select没有区别，它将用户传入的数组拷贝到内核空间，然后查询每个fd对应的设备状态，如果设备就绪则在设备等待队列中加入一项并继续遍历，如果遍历完所有的fd后没有发现就绪设备，则挂起当前进程，直到设备就绪或者主动超时，被唤醒后它又要再次遍历fd。这个过程经历了多次无谓的遍历。poll是基于链表来存储的，所以它没有最大连接数的限制，但同样有一个缺点：（1）、大量的fd的数组被整体复制于用户态和内核地址空间之间，而不管这样的复制是不是有意义。（2）、poll还有一个特点是“水平触发”,如果报告了fd后，没有被处理，那么下次poll时会再次报告该fd。

poll和netlink是Linux内核中的两个不同的概念。poll是一种系统调用，用于等待一个或多个文件描述符（例如socket或文件）上的事件。当文件描述符上有事件时，它会通知进程，使进程可以选择执行特定的操作。这在网络编程中很常见，例如等待收到数据或连接来自客户端的请求。netlink则是一种用于内核与用户空间之间通信的机制。使用netlink，内核和用户空间进程可以交换消息。在Linux内核中，netlink主要用于实现网络协议栈中的控制和诊断。例如，在Linux中，通过netlink接口可以查询系统中的网络连接，修改网络配置，并获取内核中的统计信息。因此，pollnetlink驱动程序将两个概念结合在一起。它可以监视netlink套接字以获取内核发送的消息，然后使用poll机制通知用户空间进程。这样，用户空间应用程序就可以使用poll等待内核发出的消息，并相应地处理这些消息。相对于原始的netlink驱动程序，pollnetlink驱动程序具有更高的效率和更好的响应性。

select :它仅仅知道了， 有 I/O 事件发生了，却并不知道是哪那几个流 (可能有一个，多个， 甚至全部)，我们只能无差别轮询所有流，找出能读出数据，或者写入数据的流，对他们进行 操作。所以 select 具有 O(n)的无差别轮询复杂度 ，同时处理的流越多，无差别轮询时间就 越长。 它是基于数组来存储的，它有最大连接数的限制。 poll :poll 本质上和 select 没有区别，它将用户传入的数组拷贝到内核空间，然后查询每个 fd 对应的设备状态， 但是 它没有最大连接数的限制 ，原因是 它是基于链表来存储的 . epoll :epoll 可以理解为 event poll，不同于忙轮询和无差别轮询， epoll 会把哪个流发生了 怎样的 I/O 事件通知我们 。所以我们说 epoll 实际上是事件驱动(每个事件关联上 fd)的， 此时我们对这些流的操作都是有意义的。( 复杂度降低到了 O(1) )， 通过红黑树和双链表数 据结构，并结合回调机制，造就了 epoll 的高效 ，epoll_create()，epoll_ctl()和 epoll_wait()系统调用。 这就要从 epoll 的实现方式说起了。epoll 有一棵 红黑树 用来管理你感兴趣的或者说是监控的文件描述符，这样不需要像 select 和 poll 一样每次把所有的文件描述符从用户空间拷贝到内核空间，而是通过 epoll_ctl 来进行修改。除了一棵红黑树外 还有一个就绪列表，如果文件描述符就绪 比如网络包到达，对应文件描述符加入 就绪列表 ，调用 epoll_wait 从就绪列表拿到就绪文件描述符。 水平触发也就 条件触发 ，就是只要我这个文件满足条件，就一直触发。例如只要可读，后续调用 epoll_wait 时候会一直触发直到不可读。 （ 会被重新加入就绪列表 ） 所以对于水平触发，只要一直可读就一直触发，但是触发次数多了，调用epoll_wait影响性能。 边缘触发只触发一次，容易遗漏事件, 所以你要保证你把所有数据读完为止 一般是多次读直到不可读或者多次写直到数据写完。 水平触发(level-triggered，也被称为条件触发)LT: 只要满足条件，就触发一个事件(只要有数据没有被获取，内核就不断通知你) 边缘触发(edge-triggered)ET: 每当状态变化时 ，触发一个事件。 两者的区别在哪里呢？水平触发是只要读缓冲区有数据，就会一直触发可读信号，而边缘触发仅仅在空变为非空的时候通知一次， 是水平出发，一旦注册read事件，如果不读取数据，select后会一直返回channel对应的SelectionKey

poll 是“询”，只看不拿；pop 是“拿”回家慢慢看。因此，poll 不改变容器的数据，而 pop 会拿走一个。

1、Poll是一款非常受欢迎的Modbus主站设备仿真器，支持ModbusRTU、ASCII、TCP/IP等协议模式，能够让Modbus通信设备人员测试和模拟使用通信协议，从而更好的对设备进行监控、测试和调试。2、Scan是一款标准、开放，用户可以免费、放心地使用Modbus协议，ModScan就是用来模拟Modbus通讯主设备。

select，poll，epoll都是IO多路复用的机制。I/O多路复用就是通过一种机制，可以监视多个描述符，一旦某个描述符就绪（一般是读就绪或者写就绪），能够通知程序进行相应的读写操作。 但select，poll，epoll本质上都是同步I/O ，因为他们都需要在读写事件就绪后自己负责进行读写，也就是说这个读写过程是阻塞的，而异步I/O则无需自己负责进行读写，异步I/O的实现会负责把数据从内核拷贝到用户空间。 I/O复用模型会用到select、poll、epoll函数：对一个IO端口，两次调用，两次返回，比阻塞IO并没有什么优越性。但关键是 能实现同时对多个IO端口进行监听。 这几个函数也会使进程阻塞，但是和阻塞I/O所不同的是，这几个函数 可以同时阻塞多个I/O操作。而且可以同时对多个读操作，多个写操作的I/O函数进行检测，直到有数据可读或可写时，才真正调用I/O操作函数。 当一个客户端连接上服务器时，服务器就将其连接的fd加入fd_set集合，等到这个连接准备好读或写的时候，就通知程序进行IO操作，与客户端进行数据通信。大部分Unix/Linux 都支持 select 函数，该函数用于探测多个文件描述符的状态变化。 （1） 创建所关注的事件的描述符集合（fd_set)，对于一个描述符，可以关注其上面的读(read)、写(write)、异常(exception)事件，所以通常，要创建三个fd_set，一个用来收集关注读事件的描述符，一个用来收集关注写事件的描述符，另外一个用来收集关注异常事件的描述符集合。 （2）调用select()等待事件发生。这里需要注意的一点是，select的阻塞与是否设置非阻塞I/O是没有关系的。 （3） 轮询所有fd_set中的每一个fd，检查是否有相应的事件发生，如果有，就进行处理。 优点： 相比其他模型，使用 select() 的事件驱动模型只用单线程（进程）执行，占用资源少，不消耗太多 CPU，同时能够为多客户端提供服务。如果试图建立一个简单的事件驱动的服务器程序，这个模型有一定的参考价值。 缺点： （1）每次调用select，都需要把fd集合从用户态拷贝到内核态，这个开销在fd很多时会很大！！！（复制大量句柄数据结构，产生巨大的开销 ）。 （2）同时每次调用select都需要在内核遍历传递进来的所有fd，这个开销在fd很多时也很大！！！（消耗大量时间去轮询各个句柄，才能发现哪些句柄发生了事件）。 （3）单个进程能够监视的文件描述符的数量存在最大限制，32位机默认是1024。 （4）select的触发方式是水平触发，应用程序如果没有完成对一个已经就绪的文件描述符进行IO操作，那么之后每次select调用还是会将这些文件描述符通知进程。 （5）该模型将事件探测和事件响应夹杂在一起，一旦事件响应的执行体庞大，则对整个模型是灾难性的。 poll库是在linux2.1.23中引入的，windows平台不支持poll。poll本质上和select没有太大区别，都是先创建一个关注事件的描述符的集合，然后再去等待这些事件发生，然后再轮询描述符集合，检查有没有事件发生，如果有，就进行处理。因此，poll有着与select相似的处理流程： （1）select需要为读、写、异常事件分别创建一个描述符集合，最后轮询的时候，需要分别轮询这三个集合。而poll只需要一个集合，在每个描述符对应的结构上分别设置读、写、异常事件，最后轮询的时候，可以同时检查三种事件。 （2）它没有最大连接数的限制，原因是它是基于链表来存储的。 （1）大量的fd的数组被整体复制于用户态和内核地址空间之间，而不管这样的复制是不是有意义。 （2）poll还有一个特点是“水平触发”，如果报告了fd后，没有被处理，那么下次poll时会再次报告该fd。 poll和select，它们的最大的问题就在于效率。它们的处理方式都是创建一个事件列表，然后把这个列表发给内核，返回的时候，再去轮询检查这个列表，这样在描述符比较多的应用中，效率就显得比较低下了。 epoll是一种比较好的做法，它把描述符列表交给内核，一旦有事件发生，内核把发生事件的描述符列表通知给进程，这样就避免了轮询整个描述符列表。 epoll支持水平触发和边缘触发，最大的特点在于边缘触发，它只告诉进程哪些fd刚刚变为就绪态，并且只会通知一次。还有一个特点是，epoll使用“事件”的就绪通知方式，通过epoll_ctl注册fd，一旦该fd就绪，内核就会采用类似callback的回调机制来激活该fd，epoll_wait便可以收到通知。 epoll与select和poll的调用接口上的不同：select和poll都只提供了一个函数——select或者poll函数。而epoll提供了三个函数，epoll_create,epoll_ctl和epoll_wait，epoll_create是创建一个epoll句柄；epoll_ctl是注册要监听的事件类型；epoll_wait则是等待事件的产生。 （1）创建一个epoll描述符，调用epoll_create()来完成。epoll_create()有一个整型的参数size，用来告诉内核，要创建一个有size个描述符的事件列表（集合）。 （2）给描述符设置所关注的事件，并把它添加到内核的事件列表中。这里需要调用epoll_ctl()来完成。 （3）等待内核通知事件发生，得到发生事件的描述符的结构列表。该过程由epoll_wait()完成。得到事件列表后，就可以进行事件处理了。 （1）没有最大并发连接的限制，能打开FD的上限远大于1024（1G的内存上能监听约10万个端口）； （2）效率提升。不是轮询的方式，不会随着FD数目的增加效率下降。只有活跃可用的FD才会调用callback函数； 即epoll最大的优点就在于它只管你“活跃”的连接，而跟连接总数无关，因此在实际的网络环境中，epoll的效率就会远远高于select和poll。 （3）内存拷贝。epoll通过内核和用户空间共享一块内存来实现消息传递的。利用mmap()文件映射内存加速与内核空间的消息传递；即epoll使用mmap 减少复制开销。epoll保证了每个fd在整个过程中只会拷贝一次（select，poll每次调用都要把fd集合从用户态往内核态拷贝一次）。 参考链接： select、poll、epoll总结及ET、LT区别

歌曲名:Poll (Lp Version)歌手:The Monkees专辑:HeadPolly wants a crackerThink I should get off her firstI think she wants some waterTo put out the blow torchIsn t meHave a seedLet me clipDirty wingsLet me take a rideDon t hurt yourselfWant some helpTo please myselfGot some ropeHave been toldPromise youHave been trueLet me take a rideDon t hurt yourselfWant some helpTo please myselfPolly wants a crackerMaybe she would like more foodShe asks me to untire herA chase would be nice for a fewPolly says her back hurtsShe s just as bored as meShe caught me off my guardIt amazes me the will of instincthttp://music.baidu.com/song/8245565

是一只鹦鹉

和queue里面的pop,poll一样pop：用于查看元素但是不删除poll：用于查看元素，并且把那个元素删除

1、epoll处理是事件触发，而poll是轮训方式； 2、打开的FDset限制：poll是1024.，epoll无限制； 3、poll系统调用数目增大时性能下降快

获取队列中的元素，一般是队列的头部元素。

去海词查,什么都可以解释,还有例子呢

unix下poll（）函数 函数　　Linux中的字符设备驱动中有一个函数 　　unsigned int (*poll)(struct file * fp, struct poll_table_struct * table) 　　此函数在系统调用select内部被使用，作用是把当前的文件指针挂到设备内部定义的等待 　　队列中。这里的参数table可以不考虑，是在select函数实现过程中的一个内部变量。 　　函数具体实现时： 　　wait_queue_head_t t = ((struct mydev *)filp->private_data)->wait_queue; 　　poll_wait(filp, t, table); 　　return mask; 　　这里mask可以是： 　　POLLIN | POLLRDNORM 　　POLLOUT | POLLWRNORM 　　等等。 　　poll()函数：这个函数是某些Unix系统提供的用于执行与select()函数同等功能的函数，下面是这个函数的声明： 　　#include <poll.h> 　　int poll(struct pollfd fds[], nfds_t nfds, int timeout)； 　　参数说明: 　　fds：是一个struct pollfd结构类型的数组，用于存放需要检测其状态的Socket描述符；每当调用这个函数之后，系统不会清空这个数组，操作起来比较方便；特别是对于 socket连接比较多的情况下，在一定程度上可以提高处理的效率；这一点与select()函数不同，调用select()函数之后，select() 函数会清空它所检测的socket描述符集合，导致每次调用select()之前都必须把socket描述符重新加入到待检测的集合中；因 此，select()函数适合于只检测一个socket描述符的情况，而poll()函数适合于大量socket描述符的情况； 　　nfds：nfds_t类型的参数，用于标记数组fds中的结构体元素的总数量； 　　timeout：是poll函数调用阻塞的时间，单位：毫秒； 　　返回值: 　　>0：数组fds中准备好读、写或出错状态的那些socket描述符的总数量； 　　==0：数组fds中没有任何socket描述符准备好读、写，或出错；此时poll超时，超 时时间是timeout毫秒；换句话说，如果所检测的socket描述符上没有任何事件发生的话，那么poll()函数会阻塞timeout所指定的毫秒 时间长度之后返回，如果timeout==0，那么poll() 函数立即返回而不阻塞，如果timeout==INFTIM，那么poll() 函数会一直阻塞下去，直到所检测的socket描述符上的感兴趣的事件发生是才返回，如果感兴趣的事件永远不发生，那么poll()就会永远阻塞下去； 　　-1： poll函数调用失败，同时会自动设置全局变量errno；poll实现功能　　poll和select实现功能差不多，但poll效率高，以后要多用poll 　　poll()接受一个指向结构"struct pollfd"列表的指针，其中包括了你想测试的文件描述符和事件。事件由一个在结构中事件域的比特掩码确定。当前的结构在调用后将被填写并在事件发生后 返回。在SVR4(可能更早的一些版本)中的 "poll.h"文件中包含了用于确定事件的一些宏定义。事件的等待时间精确到毫秒 (但令人困惑的是等待时间的类型却是int)，当等待时间为0时，poll()函数立即返回，-1则使poll()一直挂起直到一个指定事件发生。下面是 pollfd的结构。 　　struct pollfd { 　　int fd; /* 文件描述符 */ 　　short events; /* 等待的事件 */ 　　short revents; /* 实际发生了的事件 */ 　　}; 　　于select()十分相似，当返回正值时，代表满足响应事件的文件描述符的个数，如果返回0则代表在规定事件内没有事件发生。如发现返回为负则应该立即查看 errno，因为这代表有错误发生。 　　如果没有事件发生，revents会被清空，所以你不必多此一举。poll操作举例　　#include <fcntl.h> 　　#include <stdio.h> 　　#include <unistd.h> 　　#include <stdlib.h> 　　#include <string.h> 　　#include <time.h> 　　#include <errno.h> 　　#include <poll.h> 　　#define MAX_BUFFER_SIZE 1024 　　#define IN_FILES 3 　　#define TIME_DELAY 60*5 　　#define MAX(a,b) ((a>b)?(a):(b)) 　　int main(int argc ,char **argv) 　　{ 　　struct pollfd fds[IN_FILES]; 　　char buf[MAX_BUFFER_SIZE]; 　　int i,res,real_read, maxfd; 　　fds[0].fd = 0; 　　if((fds[1].fd=open("data1",O_RDONLY|O_NONBLOCK)) < 0) 　　{ 　　fprintf(stderr,"open data1 error:%s",strerror(errno)); 　　return 1; 　　} 　　if((fds[2].fd=open("data2",O_RDONLY|O_NONBLOCK)) < 0) 　　{ 　　fprintf(stderr,"open data2 error:%s",strerror(errno)); 　　return 1; 　　} 　　for (i = 0; i < IN_FILES; i++) 　　{ 　　fds[i].events = POLLIN; 　　} 　　while(fds[0].events || fds[1].events || fds[2].events) 　　{ 　　if (poll(fds, IN_FILES, TIME_DELAY) <= 0) 　　{ 　　printf("Poll error "); 　　return 1; 　　} 　　for (i = 0; i< IN_FILES; i++) 　　{ 　　if (fds[i].revents) 　　{ 　　memset(buf, 0, MAX_BUFFER_SIZE); 　　real_read = read(fds[i].fd, buf, MAX_BUFFER_SIZE); 　　if (real_read < 0) 　　{ 　　if (errno != EAGAIN) 　　{ 　　return 1; 　　} 　　} 　　else if (!real_read) 　　{ 　　close(fds[i].fd); 　　fds[i].events = 0; 　　} 　　else 　　{ 　　if (i == 0) 　　{ 　　if ((buf[0] == "q") || (buf[0] == "Q")) 　　{ 　　return 1; 　　} 　　} 　　else 　　{ 　　buf[real_read] = ""; 　　printf("%s", buf); 　　} 　　} 　　} 　　} 　　} 　　exit(0); 　　}

show of hands 举手表决POLL 民意调查，还是有不同的

select、poll、epoll的区别为：一、指代不同1、select：选拔。2、poll：民意测验。3、epoll：选取。二、侧重点不同1、select：select强调在进行认真的考虑后，从很多的人或物中精选出最好的、最中意的。2、poll：可用于表示无需特别仔细的挑选、辨别的某种情况。3、epoll：判断和进行实际挑选，该词强调做决定过程中所下的决心，侧重于意志或判断。三、引证用法不同1、select：select的基本意思是“选择”“挑选”，指在进行认真的考虑后，从若干事物或人中间挑选出适合要求，满足需要的事物或人。强调大范围的挑选和选择中需一定的鉴别力。2、poll：poll指剪枝，目的在于使其生长良好。3、epoll：只用作及物动词，接名词或代词作宾语，也可接以“(to be/as+) n. ”或动词不定式充当补足语的复合宾语。

select、poll 和 epoll 都是 Linux API 提供的 IO 复用方式。 多进程和多线程技术相比，I/O多路复用技术的最大优势是系统开销小，系统不必创建进程/线程，也不必维护这些进程/线程，从而大大减小了系统的开销。 我们先分析一下select函数 int select(int maxfdp1,fd_set *readset,fd_set *writeset,fd_set *exceptset,const struct timeval *timeout); 【参数说明】 int maxfdp1 指定待测试的文件描述字个数，它的值是待测试的最大描述字加1。 fd_set *readset , fd_set *writeset , fd_set *exceptset fd_set可以理解为一个集合，这个集合中存放的是文件描述符(file descriptor)，即文件句柄。中间的三个参数指定我们要让内核测试读、写和异常条件的文件描述符集合。如果对某一个的条件不感兴趣，就可以把它设为空指针。 const struct timeval *timeout timeout告知内核等待所指定文件描述符集合中的任何一个就绪可花多少时间。其timeval结构用于指定这段时间的秒数和微秒数。 【返回值】 int 若有就绪描述符返回其数目，若超时则为0，若出错则为-1 select()的机制中提供一种fd_set的数据结构，实际上是一个long类型的数组，每一个数组元素都能与一打开的文件句柄（不管是Socket句柄,还是其他文件或命名管道或设备句柄）建立联系，建立联系的工作由程序员完成，当调用select()时，由内核根据IO状态修改fd_set的内容，由此来通知执行了select()的进程哪一Socket或文件可读。 从流程上来看，使用select函数进行IO请求和同步阻塞模型没有太大的区别，甚至还多了添加监视socket，以及调用select函数的额外操作，效率更差。但是，使用select以后最大的优势是用户可以在一个线程内同时处理多个socket的IO请求。用户可以注册多个socket，然后不断地调用select读取被激活的socket，即可达到在同一个线程内同时处理多个IO请求的目的。而在同步阻塞模型中，必须通过多线程的方式才能达到这个目的。 poll的机制与select类似，与select在本质上没有多大差别，管理多个描述符也是进行轮询，根据描述符的状态进行处理，但是poll没有最大文件描述符数量的限制。也就是说，poll只解决了上面的问题3，并没有解决问题1，2的性能开销问题。 下面是pll的函数原型： poll改变了文件描述符集合的描述方式，使用了pollfd结构而不是select的fd_set结构，使得poll支持的文件描述符集合限制远大于select的1024 【参数说明】 struct pollfd *fds fds是一个struct pollfd类型的数组，用于存放需要检测其状态的socket描述符，并且调用poll函数之后fds数组不会被清空；一个pollfd结构体表示一个被监视的文件描述符，通过传递fds指示 poll() 监视多个文件描述符。其中，结构体的events域是监视该文件描述符的事件掩码，由用户来设置这个域，结构体的revents域是文件描述符的操作结果事件掩码，内核在调用返回时设置这个域 nfds_t nfds 记录数组fds中描述符的总数量 【返回值】 int 函数返回fds集合中就绪的读、写，或出错的描述符数量，返回0表示超时，返回-1表示出错； epoll在Linux2.6内核正式提出，是基于事件驱动的I/O方式，相对于select来说，epoll没有描述符个数限制，使用一个文件描述符管理多个描述符，将用户关心的文件描述符的事件存放到内核的一个事件表中，这样在用户空间和内核空间的copy只需一次。 Linux中提供的epoll相关函数如下： 1. epoll_create 函数创建一个epoll句柄，参数size表明内核要监听的描述符数量。调用成功时返回一个epoll句柄描述符，失败时返回-1。 2. epoll_ctl 函数注册要监听的事件类型。四个参数解释如下： epoll_event 结构体定义如下： 3. epoll_wait 函数等待事件的就绪，成功时返回就绪的事件数目，调用失败时返回 -1，等待超时返回 0。 epoll是Linux内核为处理大批量文件描述符而作了改进的poll，是Linux下多路复用IO接口select/poll的增强版本，它能显著提高程序在大量并发连接中只有少量活跃的情况下的系统CPU利用率。原因就是获取事件的时候，它无须遍历整个被侦听的描述符集，只要遍历那些被内核IO事件异步唤醒而加入Ready队列的描述符集合就行了。 epoll除了提供select/poll那种IO事件的水平触发（Level Triggered）外，还提供了边缘触发（Edge Triggered），这就使得用户空间程序有可能缓存IO状态，减少epoll_wait/epoll_pwait的调用，提高应用程序效率。 LT和ET原本应该是用于脉冲信号的，可能用它来解释更加形象。Level和Edge指的就是触发点，Level为只要处于水平，那么就一直触发，而Edge则为上升沿和下降沿的时候触发。比如：0->1 就是Edge，1->1 就是Level。 ET模式很大程度上减少了epoll事件的触发次数，因此效率比LT模式下高。 一张图总结一下select,poll,epoll的区别： epoll是Linux目前大规模网络并发程序开发的首选模型。在绝大多数情况下性能远超select和poll。目前流行的高性能web服务器Nginx正式依赖于epoll提供的高效网络套接字轮询服务。但是，在并发连接不高的情况下，多线程+阻塞I/O方式可能性能更好。 既然select，poll，epoll都是I/O多路复用的具体的实现，之所以现在同时存在，其实他们也是不同 历史 时期的产物

fds[1].events = POLLOUT;应该把是 fds[0].events = POLLOUT;

一般来说是放在/usr/include目录下的； 但是这个并不局限也是可控的，如果我们进行开发过程中，就会在内核的库函数文件目录：例如在:/XXX/XXX/linux-X.X/include 所以根据不同的情况，头文件存放的目录也是不同的，具体需要可以根据locate和grep命令进行查询。

异步的概念和同步相对。 （1）当一个同步调用发出后，调用者要一直等待返回消息（结果）通知后，才能进行后续的执行； （2）当一个异步过程调用发出后，调用者不能立刻得到返回消息（结果）。实际处理这个调用的部件在完成后，通过 状态、通知和回调 来通知调用者。 这里提到执行部件和调用者通过三种途径返回结果：状态、通知和回调。使用哪一种通知机制，依赖于执行部件的实现，除非执行部件提供多种选择，否则不受调用者控制。 （A）阻塞调用是指调用结果返回之前，当前线程会被挂起，一直处于等待消息通知，不能够执行其他业务 (B)非阻塞调用是指在不能立刻得到结果之前，该函数不会阻塞当前线程，而会立刻返回 场景比喻： 举个例子，比如我去银行办理业务，可能会有两种方式： 在上面的场景中，如果： a)如果选择排队(同步)，且排队的时候什么都不干(线程被挂起，什么都干不了)，是同步阻塞模型； b)如果选择排队(同步)，但是排队的同时做与办银行业务无关的事情，比如抽烟，（线程没有被挂起，还可以干一些其他的事），是同步非阻塞模型； c）如果选择拿个小票，做在位置上等着叫号（通知），但是坐在位置上什么都不干（线程被挂起，什么都干不了），这是异步阻塞模型； d）如果选择那个小票，坐在位置上等着叫号(通知)，但是坐着的同时还打电话谈生意(线程没有被挂起，还可以干其他事情)，这是异步非阻塞模型。 对这四种模型做一个总结： 1：同步阻塞模型，效率最低，即你专心排队，什么都不干。 2：异步阻塞，效率也非常低，即你拿着号等着被叫（通知），但是坐那什么都不干 3：同步非阻塞，效率其实也不高，因为涉及到线程的来回切换。即你在排队的同时打电话或者抽烟，但是你必须时不时得在队伍中挪动。程序需要在排队和打电话这两种动作之间来回切换，系统开销可想而知。 4：异步非阻塞，效率很高，你拿着小票在那坐着等叫号(通知)的同时，打电话谈你的生意。 linux下几个基本概念 1：用户控件和内核空间。 现代操作系统都是采用虚拟存储器，在32位操作系统下，它的寻址空间(虚拟存储空间)为4G(2的32次方)。为了保证用户进程补鞥呢直接操作内核，保证内核的安全，操作系统将虚拟空间划分为两部分，一部分为内核空间，一部分为用户空间。对linux操作系统而言，将最高的1G字节空间分给了内核使用，称为内核空间，将较低的3G字节的空间划分为用户空间。 2：进程切换很耗资源 ，为了控制进程的执行，内核必须有能力挂起正在cpu上运行的进程，并恢复以前挂起的某个进程的执行，这种行为叫进程的切换。每次切换，要保存上一个的上下文环境等等，总之记住进程切换很耗资源。 3：文件描述符 ：文件描述符在形式上是一个非负整数。实际上，他是一个索引，指向内核为每个进程所维护的该进程打开文件的记录表。当程序打开一个文件时，内核就会向进程返回一个非负整数的文件描述符。但是文件描述符一般在unix，linux系统中才讲。 缓存IO ，大多数系统的默认IO操作都是缓存IO,在linux的缓存IO机制中，操作系统会将IO的数据缓存在系统的页缓存(page cache)中，也就是说，数据会先被拷贝到操作系统内核的缓冲区，然后才会从操作系统内核的缓冲区拷贝到应用程序的地址空间。 缓存IO的缺点： 数据在传输过程中需要在应用程序和地址空间和内核进行多次数据拷贝操作，这种数据拷贝操作锁带来的cpu以及内存消耗是很大的。 LINUX的IO模型 网络IO的本质是socket的读取。socket在linux系统被抽象为流，故对网络IO的操作可以理解为对流的操作。 对于一次IO访问，比如以read操作为例， 数据会先被拷贝到操作系统内核的缓冲区，然后才会从内核缓冲区拷贝到进程的用户层，即应用程序的地址空间 。故当一个read操作发生时，其实是经历了两个阶段： 1：内核缓冲区的数据就位 2：数据从内核缓冲区拷贝到用户程序地址空间 那么具体到socket io的一次read操来说，这两步分别是： 1：等待网络上的数据分组到达，然后复制到内核缓冲区中 2：数据从内核缓冲区拷贝到用户程序的地址空间(缓冲区) 所以说 网络应用要处理的无非就两个问题：网络IO和数据计算 ，一般来说网络io带来的延迟影响比较大。 网络IO的模型大致有如下几种： 熟悉不？ 我们常说的select，poll和epoll就是属于同步模型中多路复用IO的不同实现方法罢了。 下面分别对同步阻塞，同步不阻塞，同步io复用进行说明。 一：同步阻塞 它是最简单也最常用的网络IO模型。linux下默认的socket都是blocking的。 从图中可以看到，用户进程调用recvfrom这个系统调用后，就处于阻塞状态。然后kernel就开始了IO的第一个阶段：数据准备。等第一个阶段准备完成之后，kernel开始第二阶段，将数据从内核缓冲区拷贝到用户程序缓冲区（需要花费一定时间）。然后kernel返回结果（确切的说是recvfrom这个系统调用函数返回结果），用户进程才结束blocking，重新运行起来。 总结 ： 同步阻塞模型下，用户程序在kernel执行io的两个阶段都被blocking住了 。但是优点也是因为这个，无延迟能及时返回数据，且程序模型简单。 二：同步非阻塞 同步非阻塞就是隔一会瞄一下的轮询方式。同步非阻塞模式其实是可以看做一小段一小段的同步阻塞模式。 三：IO多路复用 由于同步非阻塞方式需要不断的轮询，光轮询就占据了很大一部分过程，且消耗cpu资源。而这个用户进程可能不止对这个socket的read，可能还有对其他socket的read或者write操作，那人们就想到了一次轮询的时候，不光只查询询一个socket fd，而是在一次轮询下，查询多个任务的socket fd的完成状态，只要有任何一个任务完成，就去处理它。而且，轮询人不是进程的用户态，而是有人帮忙就好了。那么这就是所谓的 IO多路复用 。总所周知的linux下的select，poll和epoll就是这么干的。。。 selelct调用是内核级别的，selelct轮询相比较同步非阻塞模式下的轮询的区别为： 前者可以等待多个socket，能实现同时对多个IO端口的监听 ，当其中任何一个socket数据准备好了，就返回可读。 select或poll调用之后，会阻塞进程 ，与blocking IO 阻塞不用在于，此时的select不是等到所有socket数据达到再处理，而是某个socket数据就会返回给用户进程来处理。 其实select这种相比较同步non-blocking的效果在单个任务的情况下可能还更差一些 ，因为这里调用了select和recvfrom两个system call，而non-blocking只调用了一个recvfrom，但是 用select的优势在于它可以同时处理多个socket fd 。 在io复用模型下，对于每一个socket，一般都设置成non-blocking，但是其实 整个用户进程是一直被block的 ，只不过用户process不是被socket IO给block住，而是被select这个函数block住的。 与多进程多线程技术相比，IO多路复用的最大优势是系统开销小。 一：select select函数监视多个socket fs，直到有描述符就绪或者超时，函数返回。当select函数返回后，可以通过遍历fdset，来找到就绪的描述符。select的基本流程为： 二：poll poll本质上跟select没有区别，它将用户传入的数组拷贝到内核空间，然后查询每个fd的状态，如果某个fd的状态为就绪，则将此fd加入到等待队列中并继续遍历。如果遍历完所有的fd后发现没有就绪的，则挂起当前进程，直到设备就绪或者主动超时。被唤醒后它又要再次遍历fd。 特点： 1：poll没有最大连接数限制，因为它是用基于链表来存储的，跟selelct直接监听fd不一样。 2：同样的大量的fd的数组被整体复制与用户态和内核地址空间之间。 3：poll还有一个特点是水平触发：如果报告了fd后没有被处理，则下次poll时还会再次报告该fd。 4：跟select一样，在poll返回后，还是需要通过遍历fdset来获取已经就绪的socket。当fd很多时，效率会线性下降。 三：epoll epoll支持水平触发和边缘触发，最大的特点在于边缘触发，它只告诉进程哪些fd刚刚变为就绪态，并且只会通知一次。还有一个特点是，epoll使用“事件”的就绪通知方式，通过epoll_ctl注册fd，一旦该fd就绪，内核就会采用类似callback的回调机制来激活该fd，epoll_wait便可以收到通知。 没有最大并发连接的限制，能打开的FD的上限远大于1024（1G的内存上能监听约10万个端口）。 效率提升，不是轮询的方式，不会随着FD数目的增加效率下降。只有活跃可用的FD才会调用callback函数；即Epoll最大的优点就在于它只管你“活跃”的连接，而跟连接总数无关，因此在实际的网络环境中，Epoll的效率就会远远高于select和poll。 内存拷贝，利用mmap()文件映射内存加速与内核空间的消息传递；即epoll使用mmap减少复制开销。 聊聊同步、异步、阻塞与非阻塞 聊聊Linux 五种IO模型 聊聊IO多路复用之select、poll、epoll详解

理解Linux的IO模型之前，首先要了解一些基本概念，才能理解这些IO模型设计的依据 操作系统使用虚拟内存来映射物理内存，对于32位的操作系统来说，虚拟地址空间为4G（2^32）。操作系统的核心是内核，为了保护用户进程不能直接操作内核，保证内核安全，操作系统将虚拟地址空间划分为内核空间和用户空间。内核可以访问全部的地址空间，拥有访问底层硬件设备的权限，普通的应用程序需要访问硬件设备必须通过 系统调用 来实现。 对于Linux系统来说，将虚拟内存的最高1G字节的空间作为内核空间仅供内核使用，低3G字节的空间供用户进程使用，称为用户空间。 又被称为标准I/O，大多数文件系统的默认I/O都是缓存I/O。在Linux系统的缓存I/O机制中，操作系统会将I/O的数据缓存在页缓存（内存）中，也就是数据先被拷贝到内核的缓冲区（内核地址空间），然后才会从内核缓冲区拷贝到应用程序的缓冲区（用户地址空间）。 这种方式很明显的缺点就是数据传输过程中需要再应用程序地址空间和内核空间进行多次数据拷贝操作，这些操作带来的CPU以及内存的开销是非常大的。 由于Linux系统采用的缓存I/O模式，对于一次I/O访问，以读操作举例，数据先会被拷贝到内核缓冲区，然后才会从内核缓冲区拷贝到应用程序的缓存区，当一个read系统调用发生的时候，会经历两个阶段： 正是因为这两个状态，Linux系统才产生了多种不同的网络I/O模式的方案 Linux系统默认情况下所有socke都是blocking的，一个读操作流程如下： 以UDP socket为例，当用户进程调用了recvfrom系统调用，如果数据还没准备好，应用进程被阻塞，内核直到数据到来且将数据从内核缓冲区拷贝到了应用进程缓冲区，然后向用户进程返回结果，用户进程才解除block状态，重新运行起来。 阻塞模行下只是阻塞了当前的应用进程，其他进程还可以执行，不消耗CPU时间，CPU的利用率较高。 Linux可以设置socket为非阻塞的，非阻塞模式下执行一个读操作流程如下： 当用户进程发出recvfrom系统调用时，如果kernel中的数据还没准备好，recvfrom会立即返回一个error结果，不会阻塞用户进程，用户进程收到error时知道数据还没准备好，过一会再调用recvfrom，直到kernel中的数据准备好了，内核就立即将数据拷贝到用户内存然后返回ok，这个过程需要用户进程去轮询内核数据是否准备好。 非阻塞模型下由于要处理更多的系统调用，因此CPU利用率比较低。 应用进程使用sigaction系统调用，内核立即返回，等到kernel数据准备好时会给用户进程发送一个信号，告诉用户进程可以进行IO操作了，然后用户进程再调用IO系统调用如recvfrom，将数据从内核缓冲区拷贝到应用进程。流程如下： 相比于轮询的方式，不需要多次系统调用轮询，信号驱动IO的CPU利用率更高。 异步IO模型与其他模型最大的区别是，异步IO在系统调用返回的时候所有操作都已经完成，应用进程既不需要等待数据准备，也不需要在数据到来后等待数据从内核缓冲区拷贝到用户缓冲区，流程如下： 在数据拷贝完成后，kernel会给用户进程发送一个信号告诉其read操作完成了。 是用select、poll等待数据，可以等待多个socket中的任一个变为可读，这一过程会被阻塞，当某个套接字数据到来时返回，之后再用recvfrom系统调用把数据从内核缓存区复制到用户进程，流程如下： 流程类似阻塞IO，甚至比阻塞IO更差，多使用了一个系统调用，但是IO多路复用最大的特点是让单个进程能同时处理多个IO事件的能力，又被称为事件驱动IO，相比于多线程模型，IO复用模型不需要线程的创建、切换、销毁，系统开销更小，适合高并发的场景。 select是IO多路复用模型的一种实现，当select函数返回后可以通过轮询fdset来找到就绪的socket。 优点是几乎所有平台都支持，缺点在于能够监听的fd数量有限，Linux系统上一般为1024，是写死在宏定义中的，要修改需要重新编译内核。而且每次都要把所有的fd在用户空间和内核空间拷贝，这个操作是比较耗时的。 poll和select基本相同，不同的是poll没有最大fd数量限制（实际也会受到物理资源的限制，因为系统的fd数量是有限的），而且提供了更多的时间类型。 总结：select和poll都需要在返回后通过轮询的方式检查就绪的socket，事实上同时连的大量socket在一个时刻只有很少的处于就绪状态，因此随着监视的描述符数量的变多，其性能也会逐渐下降。 epoll是select和poll的改进版本，更加灵活，没有描述符限制。epoll使用一个文件描述符管理多个描述符，将用户关系的文件描述符的事件存放到内核的一个事件表中，这样在用户空间和内核空间的copy只需一次。 epoll_create()用来创建一个epoll句柄。 epoll_ctl() 用于向内核注册新的描述符或者是改变某个文件描述符的状态。已注册的描述符在内核中会被维护在一棵红黑树上，通过回调函数内核会将 I/O 准备好的描述符加入到一个就绪链表中管理。 epoll_wait() 可以从就绪链表中得到事件完成的描述符，因此进程不需要通过轮询来获得事件完成的描述符。 当epoll_wait检测到描述符IO事件发生并且通知给应用程序时，应用程序可以不立即处理该事件，下次调用epoll_wait还会再次通知该事件，支持block和nonblocking socket。 当epoll_wait检测到描述符IO事件发生并且通知给应用程序时，应用程序需要立即处理该事件，如果不立即处理，下次调用epoll_wait不会再次通知该事件。 ET模式在很大程度上减少了epoll事件被重复触发的次数，因此效率要比LT模式高。epoll工作在ET模式的时候，必须使用nonblocking socket，以避免由于一个文件句柄的阻塞读/阻塞写操作把处理多个文件描述符的任务饿死。 【segmentfault】 Linux IO模式及 select、poll、epoll详解 【GitHub】 CyC2018/CS-Notes

select，poll，epoll都是IO多路复用的机制。I/O多路复用就通过一种机制，可以监视多个描述符，一旦某个描述符就绪（一般是读就绪或者写就绪），能够通知程序进行相应的读写操作。但select，poll，epoll本质上都是同步I/O，因为他们都需要在读写

　　poll在1986年诞生于System V Release 3，它和select在本质上没有多大差别，但是poll没有最大文件描述符数量的限制。　　poll和select同样存在一个缺点就是，包含大量文件描述符的数组被整体复制于用户态和内核的地址空间之间，而不论这些文件描述符是否就绪，它的开销随着文件描述符数量的增加而线性增大。　　另外，select()和poll()将就绪的文件描述符告诉进程后，如果进程没有对其进行IO操作，那么下次调用select()和poll()的时候将再次报告这些文件描述符，所以它们一般不会丢失就绪的消息，这种方式称为水平触发（Level Triggered）。

可以。在teams中其他人也是可以发poll的，poll是一个自定义的应用程序，它使用户能够在聊天或频道中快速创建和发送民意调查，以了解其团队的意见。

fds[0].fd 与 fds[1].fd 同样是sock这个描述符, 其中在fds[0] 中注册POLLIN和POLLRDNORM事件, 在fds[1]中监听POLLOUT和POLLWRNORM事件, 这样做就成功了, 不会出现上述 "同时在一个sock描述符注册可读可写事件, 导致监听结果与实际不符"的现象。

不是。CK是美国著名时尚品牌，全称Calvin Klein，英文为卡尔文·克莱恩。虽然CK是个美国品牌，但是手表均在瑞士生产制造。1997年，CK又将它在服饰领域取得的辉煌写进了手表制造业。

poll意思是：作名词时意为“投票；民意测验；投票数；投票所；(Poll)人名；(德、匈、罗、英)波尔”，作及物动词时意为“投票；剪短；对…进行民意测验；获得选票”，作不及物动词时意为“投票”，作形容词时意为“无角的；剪过毛的；修过枝的”。短语搭配：xit poll票站调查 ; 出口民调 ; 出口调查；Field Poll费尔德民调 ; 田野民调；Snap Poll即席调查；straw poll测验民意的投票 ; 假投票 ; 测验民意的假投票 ; 民意调查；deliberative poll民意调查 ; 审慎思辩民调 ; 协商民意调查；例句：Have you ever done a poll or anything like that?你曾经做过什么民调或类似的活动吗？I don"t think we have to win the straw poll but we do have to show some progress.我不认为我们必须在这项草根性投票中获胜，但是我们必须表现出某些进展。But with that rise in poll standing it is likely he will get media scrutiny and then we will see whether that helps him or hurts him.可是，随着在民调中的排名上升，他很可能会受到媒体的详细审查，然后，我们将会看到这将会帮助他还是伤害他。

分类: 电脑/网络 >> 程序设计 >> 其他编程语言 问题描述: #include <sys/poll.h>int poll(struct pollfd *ufds, unsigned int nfds, int timeout);struct pollfd{int fd; /* 想查询的文件描述符. */short int events; /* fd 上，我们感兴趣的事件*/short int revents; /* Types of events that actually occurred. */};请问第二个参数unsigned int nfds的含义，它传递什么信息？ 解析: ufds 指向 struct pollfd 数组 nfds 指定 pollfd 数组元素的个数，也就是要监测几个 pollfd

polls意思是：作名词时意为“投票；民意测验；投票数；投票所；(Poll)人名；(德、匈、罗、英)波尔”，作及物动词时意为“投票；剪短；对…进行民意测验；获得选票”，作不及物动词时意为“投票”，作形容词时意为“无角的；剪过毛的；修过枝的”。短语搭配：xit poll票站调查 ; 出口民调 ; 出口调查；Field Poll费尔德民调 ; 田野民调；Snap Poll即席调查；straw poll测验民意的投票 ; 假投票 ; 测验民意的假投票 ; 民意调查；deliberative poll民意调查 ; 审慎思辩民调 ; 协商民意调查；例句：Have you ever done a poll or anything like that?你曾经做过什么民调或类似的活动吗？I don"t think we have to win the straw poll but we do have to show some progress.我不认为我们必须在这项草根性投票中获胜，但是我们必须表现出某些进展。But with that rise in poll standing it is likely he will get media scrutiny and then we will see whether that helps him or hurts him.可是，随着在民调中的排名上升，他很可能会受到媒体的详细审查，然后，我们将会看到这将会帮助他还是伤害他。

分类: 教育/科学 >> 外语学习 问题描述: Politicians pretend to ignore opinion____ A.polls B.votes 两词都有投票的之意，为什么用前者而不用后者 解析: polln. 选举之投票, 民意测验 v. 投票, 获得选票, 选举中获得 vote n. 投票, 选票,表决, 得票数 vi. 投票 vt. 投票,投票决定, 公认, <口>建议, 使投票

和queue里面的pop,poll一样pop：用于查看元素但是不删除poll：用于查看元素，并且把那个元素删除

ufds 指向 struct pollfd 数组nfds 指定 pollfd 数组元素的个数，也就是要监测几个 pollfd

select、poll、epoll都是IO多路复用的机制，但是他们的机制有很大的区别1、select select机制刚开始的时候，需要把fd_set从用户空间拷贝到内核空间，并且检测的fd数是有限制的，由FD_SETSIZE设置，一般是1024。检测的时候，根据timeout，遍历fd_set表，把活跃的fd(可读写或者错误)，拷贝到用户空间，再在用户空间依次处理相关的fd。这个机制是linux内核很早的版本，epool是根据select，pool基础上优化的，缺点比较多。缺点：1）每次调用select的时候需要把fd_set从用户空间拷贝到内存空间，比较耗性能。2）wait时，需要遍历所有的fd，消耗比较大。3）select支持的文件数大小了，默认只有1024，如果需要增大，得修改宏FD_SETSIZE值，并编译内核（麻烦，并且fd_set中的文件数多的话，每次遍历的成本就很大）。2. poolpoll的实现和select非常相似，只是描述fd集合的方式不同，poll使用pollfd结构而不是select的fd_set结构，其他的都差不多。3. epoolepool是select和poll的改进版本，* 先是使用int epoll_create(int size)在内存中创建一个指定size大小的事件空间，* 再使用int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);事件注册函数，注册新的fd到epfd的epool对象空间中，并指明event(可读写啊等等），注意：在注册新事件fd的过程中，也再内核中断处理程序里注册fd对应的回调函数callback，告诉内核，一旦这个fd中断了，就把它放到ready队列里面去。* 再使用int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);在epool对象对应的ready队列里取就绪的fd，并使用内存映射mmap拷贝到用户空间。* 再在用户空间依次处理相关的fd。优点：1）支持一个进程打开大数目的socket描述符select 一个进程打开FD是有限制的，由FD_SETSIZE设置，默认值是1024。epool可以打开的FD数可以很大，一般1GB的内存有10万多的FD数，具体数目可以cat /proc/sys/fs/file-max查看。2） IO效率不随FD数目增加而线性下降3） 使用mmap加速内核与用户空间的消息传递

第一行定义了一个线程池，表示最多可以创建poolsize这么多线程；第二行是调用makeRequests创建了要开启多线程的函数，以及函数相关参数和回调函数，其中回调函数可以不写，default是无，也就是说makeRequests只需要2个参数就可以运行；第三行用法比较奇怪，是将所有要运行多线程的请求扔进线程池，[pool.putRequest(req) for req in requests]等同于：

Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured session.timeout.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records. 造成的问题：假如consumer.properties配置中max.poll.records=40 (一次最多拉取40条数据) session.timeout.ms=30000 (会话时间) 假设kafka此时一次拉取了40条数据，但在处理第31条的时候抛出了如上的异常，就会导致，本次offset不会提交，完了这40条消息都会在接下来的某刻被再次消费，这其中就包含了其实已经消费了的30条数据 原因：the poll loop is spending too much time message processing， the time between subsequent calls to poll() was longer than the configured session.timeout.ms，好吧其实是一个意思！ 意思就是说poll下来数据后，处理这些数据的时间比 session.timeout.ms配置的时间要长，从而导致the group has already rebalanced 解决办法是最后一句话：You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records. 即要不增大 session.timeout.ms，要不减小max.poll.records ，至于具体配置为多少，得看你处理一条消息花费多长时间 x，需要满足 x乘以max.poll.records < session.timeout.ms 另一种解决思路： 解决此类重复消费的方式：将能够唯一标识消息的信息存储在其他系统，比如redis，什么能够唯一标识消息呢？就是consumergroup+topic+partition+offset，更准确的应该是consumergroup+" "+topic+" "+partition+"_"+offset组成的key,value可以是处理时间存放在redis中，每次处理kafka消息时先从redis中根据key获取value，如果value为空，则表明该消息是第一次被消费，不为空则表示时已经被消费过的消息； 参考： https://www.cnblogs.com/chinano1/p/9357725.html

两种。驱动的运行模式分为两种，中断模式和poll_mode模式，默认是中断模式，设置为1是硬件polling模式。根据实际应用场景可以选择相应的设置。

例如你在大学中读书,要等待一个朋友来访,而这个朋友只知道你在H号楼,但不知道你在哪一个房间（例如H号楼有200个寝室），select/poll()模型(也就是多路复用模型)，比如你的同学来了,select/poll比较笨,她带着你朋友挨个房间进行查询谁是同学你,找到你后，说你的朋友来了，epoll是poll的改进，他相当于登记了每个宿舍住的人的姓名，你的朋友到了H栋楼的门口，epoll(管理员)会问他，你找谁，你的朋友把你的名字一说，管理员查到你的房间号后，直接把他带到你的房间，区别就是这样，希望能帮到你！

使用非阻塞 I/O 的应用程序常常使用 poll, select, 和 epoll 系统调用。poll, select 和 epoll 本质上有相同的功能。每个都允许一个进程来决定它是否可读或者写一个或多个文件而不阻塞. 这些调用也可阻塞进程直到任何一个给定集合的文件描述符可用来读或写。 换句话说，在驱动中poll函数就是协调一次读写的设备个数或是读写设备的顺序。

你连基本概念都不知道啊，还有你提问题的态度有点火气啊！！别人会喷你的！！还好我人好，给你科普一下：public bool Poll(int microSeconds,SelectMode mode)参数microSeconds类型：System.Int32等待响应的时间（以微秒为单位）。mode类型：System.Net.Sockets.SelectModeSelectMode 值之一。请注意这个：等待响应的时间（以微秒为单位）。1秒=1000毫秒=1000000微秒算下来，你的5000是不是很渺小了啊！！也才200分之1秒钟嘛 哈哈就这样哈，自己去理解和试试！！

“polly”是什么意思：英文名字，可译成中文“波利”。

pygame.event.get ----- get events from the queuepygame.event.poll -------- get a single event from the queuefor event in pygame.event.get()上面的代码将会创建当前等待处理的事件的一个列表，然后使用for循环来遍历里面的事件。这样，我们将会根据事件产生的顺序依次地进行不同的操作。pygame.event.poll它是从等待处理事件列表中返回一个事件。

`poll` 和 `epoll` 都是 Linux 中用于实现 I/O 多路复用的机制，可以让一个进程同时监听多个文件描述符上的事件。它们的主要区别在于实现方式和性能表现。`poll` 函数是最早引入到 Linux 内核中的 I/O 多路复用机制，它使用一个 `pollfd` 结构体数组来存储需要监听的文件描述符以及每个文件描述符上需要监听的事件类型。当调用 `poll` 函数时，内核会遍历所有的 `pollfd` 结构体，检查每个文件描述符上是否有事件发生，如果有则将该事件通知给应用程序。但是当需要监听大量文件描述符时，由于 `poll` 函数是线性扫描整个数组来查找就绪文件描述符，因此效率较低。而 `epoll` 函数则采用了基于事件驱动（Event-driven）的方式来实现 I/O 多路复用。它使用一个红黑树（Red-Black Tree）来存储需要监听的文件描述符，并通过回调函数机制来通知应用程序哪些文件描述符上发生了事件。相比于 `poll` 函数，`epoll` 函数在处理大量并发连接时具有更高的效率和更低的系统开销。总结一下：- `poll` 是最早引入到 Linux 内核中的 I/O 多路复用机制，`epoll` 是后来引入的。- `poll` 使用一个数组来存储需要监听的文件描述符，效率较低；而 `epoll` 使用红黑树和回调函数机制，效率更高。- `epoll` 可以同时监听大量文件描述符上的事件，并且可以支持边缘触发（Edge Triggered）和水平触发（Level Triggered）两种模式。

Windows没有epoll机制，不过有个相似的东西叫做完成端口

（一）消费者和消费者组 1、消费者：订阅并消费kafka消息，从属于消费者组 2、消费者组：一个群组里的消费者订阅的是同一个主题，每个消费者接受主题一部分分区的消息。 注：同一个消费者可以消费不同的partition，但是同一个partition不能被不同消费者消费。 （二）消费者群组和分区再均衡 1、再均衡：分区的消费所有权从一个消费者转移到另一个消费者称为再均衡，为消费者组带来了高可用性和可伸缩性。 注：分区何时重新分配：加入消费者或者消费者崩溃等 2、如何判断消费者崩溃：消费者通过向群组协调器（某broker，不同群组可以有不同的群组协调器）发送心跳（一般在拉取消息或者提交偏移量的时候）表示自己仍旧存活，如果长时间不发送心跳则协调器认为期死亡并进行再均衡。 注：在0.10.1版本中，心跳行为不再和获取消息和提交偏移量绑定在一起，有一个单独的心跳线程。 3、分配分区：消费者加入消费者组是，会像群组协调器发送请求，第一个加入的成为“群主”。群主从协调器那里获取成员列表，并负责给每一个消费者分配分区。完毕之后，将分配结果发送给协调器，协调器再将消息发送给所有的消费者，每个消费者只能看到自己的分配信息。只有群主知道所有的消费信息。 （三）参数配置 1、bootstrap.server：host:port 2、key.serializer：键序列化器 3、value.serializer：值序列化器 注：以上为必须设置的 4、group.id：从属的消费者组 5、fetch.min.bytes：消费者从服务器获取记录的最小字节数。 6、fetch.max.wait.ms：消费者等待消费消息的最大时间 7、max.partition.fetch.bytes：服务器从每个分区返回给消费者的最大字节数（需要比broker的设置max.message.size属性配置大，否则有些消息无法消费） 8、session.timeout.ms：指定该消费者在被认为死亡之前可以与服务器断开连接的时间，默认3秒 9、heartbeat.interval.ms：制定了poll方法向协调器发送心跳的频率。 注：一般9是8的三分之一 10、auto.offset.reset：消费者在读取一个没有偏移量分区或者无效偏移量分区的情况下如何处理（latest：从最新记录开始读取，earliest：从最早的记录开始读取） 11.、enable.auth.commit：消费者是否自动提交偏移量，默认为true 12、auto.commit.interval.ms：自动提交偏移量的时间间隔 13、partition.assignment.strategy：分区分配给消费者的策略： （1）range：会把主题若干个连续分区分配给消费者 （2）roundRobin：会把主题的所有分区逐个分配给消费者 14、client.id：任意字符串，broker用来区分客户端发来的消息 15：max.poll.records：控制poll方法返回的最大记录数 16：receive.buffer.bytes/send.buffer.bytes：tcp缓冲池读写大小 （四）订阅主题 consumer.subscribe(list) （五）轮训（消费者API的核心） 1、轮训作用： 只要消费者订阅了主题，轮训就会处理所有的细节（群组协调、分区再均衡、发送心跳、获取数据） （1）获取数据 （2）第一次执行poll时，负责查找协调器，然后加入群组，接受分配的分区 （3）心跳的发送 （4）再均衡也是在轮训期间进行的 2、方法：poll()，消费者缓冲区没有数据时会发生阻塞，可以传一个阻塞时间，避免无限等待。0表示立即返回。 3、关闭：close()，网络连接随之关闭，立即触发再均衡。 4、线程安全：无法让一个线程运行多个消费者，也无法让多个线程公用一个消费者。 （六）提交和偏移量 1、提交：更新分区当前位置的操作 2、如何提交：消费者往一个特殊主题（_consumer_offset）发送消息，消息中包含每个分区中的偏移量。 3、偏移量：分区数据被消费的位置。 4、偏移量作用：当发生再均衡时，消费者可能会分配到不一样的分区，为了继续工作，消费者需要读取到每个分区最后一次提交的偏移量，然后从偏移量的地方继续处理。 5、提交偏移量的方式 （1）自动提交：经过一个时间间隔，提交上一次poll方法返回的偏移量。每次轮训都会检测是否应该提交偏移量。缺陷：可能导致重复消费 （2）手动提交：commitSysn（）提交迁移量，最简单也最可靠，提交由poll方法返回的最新偏移量。缺点：忘了提交可能会丢数据，再均衡可能会重复消费 （3）异步提交：同步提交在提交过程中必须阻塞 （4）同步异步提交组合 （5）提交特定的偏移量 （七）再均衡监听器 （八）从特定偏移量读取数据（seek） 1、从分区开始：seekToBegining 2、从分区结束：seekToEnd 3、ConsumerRebalanceListener和seek结合使用 （九）如何退出 1、前言：wakeup方法是唯一安全退出轮训的方法，从poll方法中退出并抛出wakeupException异常。如果没有碰上轮训，则在下一次poll调用时抛出。 2、退出轮训 （1）另一个线程调用consumer.wakeup方法 （2）如果循环在主线程里可以在ShutdownHook里面调用该方法 3、退出之前调用close方法：告知协调器自己要离开，出发再均衡，不必等到超时。 （十）独立消费者（assign为自己分配分区）

在用户程序中，select()和poll()也是与设备阻塞和非阻塞访问相关的内容。 使用非阻塞IO的应用程序通常会使用select()和poll()系统调用查询是否可以对设备进行无阻塞的访问。 select()和poll()系统调用最终会使设备驱动中的poll()函数执行，在后续的Linux内核版本中还引入了epoll(),即扩展的poll()。 select()和poll()系统调用的本质是一样的，前者在BSD Unix中引入，后者在System V中引入。 应用程序中使用最广泛的是BSD Unix中引入的select()系统调用，原型如下： 如下图所示， 第一次对n个文件进行select()的时候，若任何一个文件满足要求，select()就直接返回； 第二次再进行select()的时候，没有文件满足读写要求，select()的进程阻塞且睡眠。 由于调用select()的时候，每个驱动的poll()接口都会被调用到。实际上执行select()的进程被挂到了每个驱动的等待队列上，可以被任何一个驱动唤醒。如果FDn变得可读写，select()返回。 poll()的功能和实现原理与select()类似，其原型函数为： 当多路复用的文件数量庞大、IO流量频繁的时候，一般不太适合使用select()和poll()，这种情况下select()和poll()表现较差，推荐使用epoll()。 使用epoll()最大的好处就是不会随着fd数目的增长而降低效率，select()则会随着fd数量增大性能明显下降。 相关接口： 创建一个epoll()的句柄，size用来告诉内核要监听多少个fd，当创建好epoll()句柄时，它本身也会占用一个fd值，所以在使用完epoll()后，必须调用close()关闭。 告诉内核要监听什么类型的事件： 第一个参数epfd是epoll_create()的返回值， 第二个参数表示动作，包含： 第3个参数是需要监听的fd， 第4个参数是告诉内核需要监听的事件类型，struct_epoll_event结构如下： events可以是以下几个宏的”或“： 一般来说，当涉及的fd数量较少时，使用select是合适的；如果涉及的fd很多，如在大规模并发的服务器中监听许多socket的时候，则不太适合选用select，适合使用epoll。

poll：民意测验，民意调查；选举投票，计票；投票数。PO：邮局，Post Office的缩写。我没懂你写的什么。

在一次民意测验

zk通过Multi-Paxos思想实现分布式一致性，Multi-Paxos为了解决Paxos需要2轮RPC通讯(准备阶段和接受阶段)往返消息多、耗性能、延迟大的问题引入了Leader-Follower-Learner模式；考虑到高可用性，有Leader就会涉及选举Leader的问题，本节就来分析下zk是如何实现选主的； 以三个节点同时启动为例： 以3个节点中Server1作为Follower重启为例： 以4个节点中Server4作为Leader宕机为例： Leader ：一个zk集群同一时刻只有一个Leader，所有写操作必须通过Leader完成，然后再广播给其他服务器； Follower ：一个zk集群同一时刻有多个Follower。Follower可以直接处理读请求，但是写请求需要转发给Leader处理，同时负责在Leader处理写请求时对请求进行投票； Observer ：功能跟Follower类似，但是没有投票权； Looking ：寻找Leader状态，处于该状态的服务器会发起选主； Following ：跟随者状态，表明当前服务器是Follower； Leading ：领导者状态，表明当前服务器是Leader; Observing ：观察者状态，表明当前服务器是Observer; Listener.run 监听2888端口，阻塞在ServerSocket.accept，等待其他服务器请求创建连接； RecvWorker.run 阻塞在DataInputStream.read，获取对应服务器发送的投票信息； SendWorker.run 阻塞在ArrayBlockingQueue.poll，获取待发送消息，发送给对应服务器； WorkerReceiver.run 阻塞在recvqueue.poll，获取RecvWorker.run中接收的投票消息Notification； WorkerSender.run 阻塞在sendqueue.poll，获取待发送ToSend到SendWorker.run进行处理； QuorumPeer.run 集群模式启动过程中选举结束后，根据当前服务器状态进行之后的异步流程处理； LinkedBlockingQueue<ToSend> sendqueue FastLeaderElection中的请求发送队列，存放的是ToSend； LinkedBlockingQueue<Notification> recvqueue FastLeaderElection中的请求接受队列，存放的是Notification； ConcurrentHashMap<Long, SendWorker> senderWorkerMap sid -> 当前服务器到该sid的SendWorker；每个服务器会跟比自己sid小的服务器创建一个SendWorker用于投票选主时发送投票信息； ConcurrentHashMap<Long, ArrayBlockingQueue<ByteBuffer>> queueSendMap sid -> 当前服务器需要发送到该sid的投票消息的队列；WorkerSender.run中会根据不同sid把对用的选票信息放入对应的ArrayBlockingQueue中； ConcurrentHashMap<Long, ByteBuffer> lastMessageSent sid->最后一次发送到该sid的投票信息； ArrayBlockingQueue<Message> recvQueue WorkerReceiver.run中接收到的投票信息，解析字节流转成Message放到recvQueue中； zk选主涉及6个线程、多个集合，过程比较饶，必须要先把选主的流程和各个线程、集合的作用等搞清楚，不然理解起来比较难。下一节通过源码来具体分析选主的实现； ------ over ------

你需要apply，不是map。具体信息查对应method的文档。