epoll +非阻塞套接字慢于阻塞+超时？

我有两个版本的Python编写的简单套接字服务器。第一个版本使用epoll + nonblocking aproach，并且似乎比阻塞套接字+超时的服务器版本要慢。epoll +非阻塞套接字慢于阻塞+超时？

非阻塞服务器产生10个孩子和孩子在套接字上进行接受。在这种情况下，所有的孩子都得到EPOLLIN通知，但只有一个孩子可以做接受，所有其他孩子都会得到EAGAIN，这被“除外”忽略。

--- server-nonblocking.py ---

import socket, time, os, select 

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
sock.bind(('127.0.0.1', 10000)) 
sock.listen(512) 
sock.setblocking(False) 


for _ in range(0,10): 

    pid = os.fork() 
    if pid == 0: #in child 
     poll = select.epoll() 
     poll.register(sock.fileno(), select.EPOLLIN) 

     while True: 
      events = poll.poll(3) # listening for events with 2 sec timeout 
      for fileno, event in events: 
       if event & select.EPOLLIN: # there is data on socket available 
        print("EPOLLIN in PID: " + str(os.getpid())) 
        try: 
         clientsock, addr = sock.accept() 
         clientsock.close() 
         print("accepted and closed in PID: " + str(os.getpid())) 
        except: 
         pass 


# we are in parent process, keep it live 
while True: 
    time.sleep(10)

阻塞服务器也滋生10个孩子，但在监听套接字而是使用超时，超时由except块拦截并忽略：

--- server-blocking.py ---

import socket, time, os, select 

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
sock.bind(('127.0.0.1', 10000)) 
sock.listen(512) 
sock.settimeout(5) 


for _ in range(0,10): 

    pid = os.fork() 
    if pid == 0: #in child 
     while True: 
      try: 
       clientsock, addr = sock.accept() 
       clientsock.close() 
       print("accepted and closed in PID: " + str(os.getpid())) 
      except: 
       pass 


# we are in parent process, keep it live 
while True: 
    time.sleep(10)

和她e是客户。它只在环路中连接到服务器并关闭连接。 20秒后。循环将被中断。

--- client.py ---

import socket, time, select, sys 

i = 1 
td = time.time() 
while True: 
    print("loop " + str(i) + ", time: " + str(time.time() - td)) 
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    s.connect(('localhost',10000)) 
    s.setblocking(False) 
    s.close() 
    i += 1 
    if time.time() - td >= 20: 
     break

这里是两台服务器的结果：

blocking: 
loop 137670, time: 19.99994468688965 

non-blocking: 
loop 94051, time: 19.10340452194214

阻塞服务器可以处理方式比非更多的连接阻止服务器。当客户端使用非阻塞版本，我可以看到循环上的一些延迟。

有人可以解释这种行为吗？为什么在epoll +非阻塞循环中有一些延迟？

谢谢！

来源

2014-11-05 user2624744

epoll（）对于（来自手册页，epoll（2））是有用的：监视多个文件描述符以查看它们中的任何一个上是否可能有I/O。

您正在使用epoll（）来监视一个文件描述符。这在上下文切换方面增加了一堆开销;每个孩子都必须调用epoll_create（），epoll_ctl（）和epoll_wait（）。接着！他们都被唤醒了每一个新的连接。接着！他们中的大多数都会因接受而失败。

在阻塞版本中，可能只有一个孩子被唤醒。

来源

2014-11-05 15:06:29 kidfrijoles

epoll +非阻塞套接字慢于阻塞+超时？

回答

相关问题