我有一个简单的问题。
例如,当我使用示例代码创建python TCPServer时:
import sys, SocketServer, os
from multiprocessing import Pool, Queue
class MyTCPHandler(SocketServer.BaseRequestHandler):
def handle(self):
# self.request is the TCP socket connected to the client
self.data = self.request.recv(1024).strip()
print "{} wrote:".format(self.client_address[0])
print self.data
# just send back the same data, but upper-cased
self.request.sendall(self.data.upper())
if __name__ == '__main__':
pool = Pool(processes=2)
HOST, PORT = "localhost", 9999
server = SocketServer.TCPServer((HOST,PORT), MyTCPHandler )
server.serve_forever()我的问题是:如何传递给MyTCPHandler对象池的类上的函数句柄?
谢谢
发布于 2012-07-19 00:36:22
如果你想拥有一个多线程的TCPServer,你可以像这样使用ThreadingMixIn混入类:
import SocketServer
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
pass你也可以像以前一样使用ForkingMixIn来创建一个基于fork的TCPServer。
更多信息可以在doc中找到。
https://stackoverflow.com/questions/11546060
复制相似问题