import Queue import SocketServer node_queue = Queue.LifoQueue() class TCPQueueHandler(SocketServer.BaseRequestHandler): def handle(self): self.data = self.request.recv(1024).strip() if self.data == "get": out = node_queue.get(False) self.request.send(str(out)) elif self.data.startswith("put"): d = self.data.split()[1] node_queue.put(d) if __name__ == "__main__": HOST, PORT = "localhost", 9999 server = SocketServer.TCPServer((HOST, PORT), TCPQueueHandler) server.serve_forever()