Abhishek K said the following on 8/24/2010 12:00 PM:
The method I was looking for wasclass Extended_thread(Threading.thread): def run(a) #some logic context=zmq.Context() socket=context.socket(zmq.REP) socket.bind('tcp://127.0.0.1:5555 <http://127.0.0.1:5555/>') while True: message=socket.recv() new Extended_thread(socket)
Wait - that's creating a new thread for every message you receive. That's going to be incredibly expensive.
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
