Slow Queue.queue? (was: slow network)

L

Laszlo Nagy

I had this test program originally that sent message over TCP/IP.
Messages where buffered two a Queue.Queue instances, one for incoming
and one for outgoing.

#1. endpoint.send_message(msg) -> endpoint.outgoing.put(msg)
#2. endpoint._process_outgoing() is a thread, that does:
endpoint.write_into_socket( endpoint.outgoing.get() )

On the other side:

#1 endpoint._process_incoming() is a thread, that does
endpoint.incoming.put( endpoint.read_from_socket() )
#2 endpoing.recv_messages() -> return endpoint.incoming.get()

This could do 130 message pairs/sec on Linux (on 127.0.0.1) and only 20
message pairs /sec on Windows XP.

If do not start the _process_outgoing() thread, and do not use the
outgoing queue:

#1. endpoint.send_message(msg) -> endpoint.write_into_socket(msg)

then the speed goes up to 64 messages/sec on windows and 500
messages/sec on Linux.

This has nothing to do with TCP/IP. The only change is that I'm not
using a queue, and not using +1 thread. How can this slow down my
program? Is it a problem with Queue.Queue, or with the +1 thread?

Thanks,

Laszlo
 

Ask a Question

Want to reply to this thread or ask your own question?

You'll need to choose a username for the site, which only take a couple of moments. After that, you can post your question and our members will help you out.

Ask a Question

Members online

No members online now.

Forum statistics

Threads
473,769
Messages
2,569,580
Members
45,055
Latest member
SlimSparkKetoACVReview

Latest Threads

Top