Sorry for answering my own question, but I found a way to get this
information and I thought it may be helpful for other users.
threadpool = reactor.threadpool
num_threads = threadpool.workers
q_size = threadpool.q.qsize()
num_threads is a good approximation of how many functions are
currently active, and q_size is the number still pending.
Now for another question:
- Has anyone extended threadpool to allow code to remove queued
functions from the pending queue?
I need this capability so I can cull off pending queries that are not
still needed.
-Allen
On 6/4/07, Allen Bierbaum
I am using deferToThread in my application to put a number of web service queries into the background and then respond to them when they are complete. This is all working very well, but once in a while I seem to overload the web service with queries and I would like to track this down by checking to see how many queries are in flight and how many are still waiting to be processed.
One I have put an action into the background using deferToThread, is there a way to check to see how many functions are currently processing and similarly how many functions are waiting to be processed?
Thanks, Allen