1 import socket 2 import threading 3 import SocketServer 4 5 -class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler): 6 7 - def __init__(self, port): 8 self.port = port 9 10 - def handle(self): 11 data = self.request.recv(1024) 12 cur_thread = threading.current_thread() 13 response = "{}: {}".format(cur_thread.name, data) 14 self.request.sendall(response) 15 16 -class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer): 17 pass 18