Stackless python网络性能随着时间的推移而降低？

所以我用堆栈python，写一个非常简单的网络服务器，教自己用microthreads/tasklets编程。但现在对我的问题，当我在Apache板凳上运行诸如ab -n 100000 -c 50 http://192.168.0.192/（100k请求，50个并发）时，我得到类似6k的请求/秒，第二次运行它我得到5.5k，第三次5k，第四次，4.5 k等一路下降到100req/s什么的。Stackless python网络性能随着时间的推移而降低？

但是，当我重新启动python脚本时，问题就消失了。

现在我的问题是为什么？我忘了删除小工具吗？我已经检查了stackless.getruncount（）（并且由于某种原因它总是返回1），所以它看起来好像没有任何死的tasklets在附近？我试过在完成的所有tasklet上调用.kill（），并没有帮助。我无法弄清楚这一点。

import socket 
import select 
import stackless 
import time 

class socket_wrapper(object): 
    def __init__(self, sock, sockets): 
     super(socket_wrapper, self).__init__() 
     self.sock = sock 
     self.fileno = sock.fileno 
     self.sockets_list = sockets 
     self.channel = stackless.channel() 
     self.writable = False 
     self.error = False 

    def remove(self): 
     self.sock.close() 
     self.sockets_list.remove(self) 

    def send(self, data): 
     self.sock.send(data) 

    def push(self, bytes): 
     self.channel.send(self.sock.recv(bytes)) 

def stackless_accept(accept, handler, recv_size=1024, timeout=0): 
    sockets = [accept] 

    while True: 
     read, write, error = select.select(sockets, sockets, sockets, timeout) 

     for sock in read: 
      if sock is accept: 
       # Accept socket and create wrapper 
       sock = socket_wrapper(sock.accept()[0], sockets) 

       # Create tasklett for this connection 
       tasklet = stackless.tasklet(handler) 
       tasklet.setup(sock) 

       # Store socket 
       sockets.append(sock) 

      else: 
       # Send data to handler 
       sock.push(recv_size) 

     # Tag all writable sockets 
     for sock in write: 
      if sock is not accept: 
       sock.writable = True 

     # Tag all faulty sockets 
     for sock in error: 
      if sock is not accept: 
       sock.error = True 
      else: 
       pass # should do something here if the main socket is faulty 

     timeout = 0 if socket else 1 
     stackless.schedule() 

def simple_handler(tsock): 
    data = "" 

    while data[-4:] != "\r\n\r\n": 
     data += tsock.channel.receive() 

    while not tsock.writable and not tsock.error: 
     stackless.schedule() 

    if not tsock.error: 
     tsock.send("HTTP/1.1 200 OK\r\nContent-length: 8\r\n\r\nHi there") 
     tsock.remove() 

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
sock.bind(("192.168.0.192", 8000)) 
sock.listen(5) 

stackless.tasklet(stackless_accept)(sock, simple_handler) 
stackless.run()

来源

2009-02-16 thr

两件事。

首先，请使类名以大写字母开头。这是更传统和更容易阅读。

更重要的是，在stackless_accept函数中，您累积了list个对象，其名称为sockets。这份名单似乎无限增长。是的，你有一个remove，但它不是总是调用。如果套接字出现错误，那么看起来它将永远留在集合中。

来源

2009-02-16 22:52:41

Stackless python网络性能随着时间的推移而降低？

回答

相关问题