then the speed goes up to 64 messages/sec on windows and 500
messages/sec on Linux.
Finally I could reach 1500 messages/sec without using the queue. If I
comment out one line (use the queue instead of direct write into socket)
then speed decreases to 40-60 messages/sec. I don't understand why the
slow version is slower by a factor of 40?
Fast version:
def send_message(self,sender,recipient,msgtype,body,timeout=3600):
self.write_str(self.serializer.serialize([sender,recipient,msgtype,body]))
Slow version:
def send_message(self,sender,recipient,msgtype,body,timeout=3600):
self.outgoing.put(self.serializer.serialize([
sender,recipient,msgtype,body
]),1,timeout)
plus this method, executed in a different thread:
def _process_outgoing(self):
try:
while not self.stop_requested.isSet():
data_ok = False
while not self.stop_requested.isSet():
try:
data = self.outgoing.get(1,1)
data_ok = True
break
except Queue.Empty:
pass
if data_ok:
self.write_str(data)
except Exception, e:
if self.router:
if not isinstance(e,TransportClosedError):
self.router.logger.error(dumpexc(e))
self.router.unregister_endpoint(self)
self.shutdown()
raise SystemExit(0)
--
http://mail.python.org/mailman/listinfo/python-list
