有人可以解释epoll
,poll
和线程池之间的区别吗?
- 有什么优点/缺点?
- 对框架有什么建议吗?
- 对简单/基本教程有什么建议吗?
- 似乎
epoll
并且poll
是特定于 Linux 的...... Windows 是否有等效的替代方案?
有人可以解释epoll
,poll
和线程池之间的区别吗?
epoll
并且poll
是特定于 Linux 的...... Windows 是否有等效的替代方案?线程池与 poll 和 epoll 并不真正属于同一类别,因此我假设您指的是线程池,如“线程池处理多个连接,每个连接一个线程”。
epoll
使用,虽然显而易见的方法(所有线程阻塞 on epoll_wait
)是没有用的,因为 epoll 会唤醒每个等待它的线程,所以它仍然会有同样的问题。
futex
是你的朋友吗,结合每个线程的快进队列。尽管文档记录不充分且笨拙,但futex
提供了所需的内容。epoll
一次可能会返回多个事件,并futex
让您以精确控制的方式有效地一次唤醒N个阻塞线程(N 是min(num_cpu, num_events)
理想的),并且在最好的情况下它根本不涉及额外的系统调用/上下文切换。fork
(又名旧时尚线程池)
fork
上也不是“免费的”,尽管开销主要由写时复制机制合并。在也被修改的大型数据集上,大量的页面错误fork
可能会对性能产生负面影响。poll
/select
epoll
epoll_ctl
)
epoll_wait
)
poll
工作方式timerfd
与and配合得非常好eventfd
(令人惊叹的计时器分辨率和准确性,也是)。signalfd
,消除了对信号的笨拙处理,以一种非常优雅的方式使它们成为正常控制流的一部分。eventfd
,但需要(迄今为止)未记录的功能。poll
但性能可能相同或更好。epoll
不能做“魔术”,即就发生的事件数量而言,它仍然必然是 O(N) 。epoll
与新的recvmmsg
系统调用配合得很好,因为它一次返回多个就绪通知(尽可能多的可用,直到您指定的任何内容maxevents
)。这使得在繁忙的服务器上通过一个系统调用接收例如 15 条 EPOLLIN 通知成为可能,并通过第二个系统调用读取相应的 15 条消息(系统调用减少了 93%!)。不幸的是,一个调用上的所有操作都recvmmsg
引用同一个套接字,因此它对于基于 UDP 的服务非常有用(对于 TCP,必须有一种recvmmsmsg
系统调用,它也需要每个项目的套接字描述符!)。EAGAIN
即使在使用时也应检查,epoll
因为存在epoll
报告准备就绪和后续读取(或写入)仍会阻塞的特殊情况。poll
某些内核上的/也是这种情况select
(尽管它可能已被修复)。EAGAIN
返回时,可能会无限期地从快速发送方读取新传入数据,同时完全饿死慢速发送方(只要数据保持足够快,您可能会很长时间看不到EAGAIN
! )。以同样的方式适用于poll
/ 。select
epoll_wait
(或者自打开描述符以来,如果没有先前的调用)。epoll_wait
表明自从任何人最后一次调用或 epoll_wait
描述符上的读/写函数,然后只向下一个调用或已经阻塞的线程再次报告准备情况,对于任何 人epoll_wait
在描述符上调用读(或写)函数之后发生的任何操作“。这有点道理,也......这并不完全是文档所建议的。kqueue
epoll
,不同的用法,类似的效果。libevent -- 2.0 版本还支持 Windows 下的完成端口。
ASIO——如果你在你的项目中使用了 Boost,不要再犹豫了:你已经将它作为 boost-asio 提供了。
上面列出的框架带有大量文档。Linux文档和 MSDN 广泛解释了 epoll 和完成端口。
使用 epoll 的小教程:
int my_epoll = epoll_create(0); // argument is ignored nowadays
epoll_event e;
e.fd = some_socket_fd; // this can in fact be anything you like
epoll_ctl(my_epoll, EPOLL_CTL_ADD, some_socket_fd, &e);
...
epoll_event evt[10]; // or whatever number
for(...)
if((num = epoll_wait(my_epoll, evt, 10, -1)) > 0)
do_something();
IO 完成端口的迷你教程(注意两次使用不同的参数调用 CreateIoCompletionPort):
HANDLE iocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0, 0); // equals epoll_create
CreateIoCompletionPort(mySocketHandle, iocp, 0, 0); // equals epoll_ctl(EPOLL_CTL_ADD)
OVERLAPPED o;
for(...)
if(GetQueuedCompletionStatus(iocp, &number_bytes, &key, &o, INFINITE)) // equals epoll_wait()
do_something();
(这些 mini-tuts 省略了所有类型的错误检查,希望我没有打错字,但它们在大多数情况下应该可以给你一些想法。)
编辑:
请注意,完成端口(Windows)在概念上与 epoll(或 kqueue)相反。顾名思义,它们发出的信号是完成,而不是准备就绪。也就是说,您触发一个异步请求并忘记它,直到一段时间后您被告知它已经完成(成功或不太成功,并且还有“立即完成”的例外情况)。
使用 epoll,您会一直阻塞,直到您被通知“一些数据”(可能只有一个字节)已经到达并且可用,或者有足够的缓冲区空间以便您可以在不阻塞的情况下执行写入操作。只有这样,您才开始实际操作,然后希望它不会阻塞(与您期望的不同,对此没有严格的保证——因此最好将描述符设置为非阻塞并检查 EAGAIN [EAGAIN和EWOULDBLOCK对于套接字,因为天哪,标准允许两个不同的错误值])。