Threading Pool Event()

[Graeme Matthew]

Hi all

I just cannot seem to find any documentation that shows an example of using
the factory method Event() in threads. I have a thread pool and if there are
no jobs in a Queue I want them to wait for something to be inserted. When a
job is inserted I want to send an Event, the first thread that picks it up
runs with the job the rest wait for another insert Event.

I have been looking at some C, c++ implementations and some use a continious
loop within a thread that polls the queue then if one is found pops it from
the queue and runs with it.

Problem when threads are dormant is it not better having the main thread
(i.e process) sending a signal rather than 10 threads polling surely this is
cpu intensive ??

any helps or references on Event() is much appreciated

many thanks

Graeme

[Aahz]

In article <0t************ ****@nnrp1.ozem ail.com.au>,
Graeme Matthew <gs*******@ozem ail.com.au> wrote:

I just cannot seem to find any documentation that shows an example of
using the factory method Event() in threads. I have a thread pool and
if there are no jobs in a Queue I want them to wait for something to
be inserted. When a job is inserted I want to send an Event, the first
thread that picks it up runs with the job the rest wait for another
insert Event.

Given that you're already using a Queue, there is no, repeat NO, reason
for using an Event. Just have your threads block on the Queue.
--
Aahz (aa**@pythoncra ft.com) <*> http://www.pythoncraft.com/

A: No.
Q: Is top-posting okay?

[Graeme Matthew]

Aahz

Thanks, ive actually been using your OSCON slides which have helped a lot.
So it technically correct that all worker threads in a thread pool are
either doing some work or polling the queue to find out if there is a job
to process ?

eg: (pseudocodish :-))

def run(self):

while 1:

self.lock.acqui re()

if QueueManager.Ha sJob:
job = QueueManager.Ge tFreeJob()
__processJob(jo b)

self.lock.relea se()

def __processJob(se lf):

blah blah blah .....
many thanks ......
"Aahz" <aa**@pythoncra ft.com> wrote in message
news:bf******** **@panix1.panix .com...

In article <0t************ ****@nnrp1.ozem ail.com.au>,
Graeme Matthew <gs*******@ozem ail.com.au> wrote:

I just cannot seem to find any documentation that shows an example of
using the factory method Event() in threads. I have a thread pool and
if there are no jobs in a Queue I want them to wait for something to
be inserted. When a job is inserted I want to send an Event, the first
thread that picks it up runs with the job the rest wait for another
insert Event.
Given that you're already using a Queue, there is no, repeat NO, reason
for using an Event. Just have your threads block on the Queue.
--
Aahz (aa**@pythoncra ft.com) <*>

http://www.pythoncraft.com/
A: No.
Q: Is top-posting okay?

[Aahz]

In article <ND************ *****@nnrp1.oze mail.com.au>,
Graeme Matthew <gs*******@ozem ail.com.au> wrote:

Thanks, ive actually been using your OSCON slides which have helped a
lot. So it technically correct that all worker threads in a thread
pool are either doing some work or polling the queue to find out if
there is a job to process ?
The whole point is that it *doesn't* poll. It blocks on a lock internal
to the Queue object. That makes it extremely efficient.
eg: (pseudocodish :-))

def run(self):

while 1:

self.lock.acqui re()

if QueueManager.Ha sJob:
job = QueueManager.Ge tFreeJob()
__processJob(jo b)

self.lock.relea se()

def __processJob(se lf):

blah blah blah .....

Nope, it's even simpler than that:

def run(self):
done = False
while not done:
job = q.get()
if job.done:
done = True
else:
__processJob(jo b)

The Queue handles all the locks for you.
--
Aahz (aa**@pythoncra ft.com) <*> http://www.pythoncraft.com/

A: No.
Q: Is top-posting okay?

[Cliff Wells]

On Fri, 2003-07-18 at 14:28, Graeme Matthew wrote:

Aahz

Thanks, ive actually been using your OSCON slides which have helped a lot.
So it technically correct that all worker threads in a thread pool are
either doing some work or polling the queue to find out if there is a job
to process ?
They don't poll the queue, they block waiting on it until something is
available.
eg: (pseudocodish :-))

def run(self):

while 1:

self.lock.acqui re()

if QueueManager.Ha sJob:
job = QueueManager.Ge tFreeJob()
__processJob(jo b)

self.lock.relea se()

def __processJob(se lf):

blah blah blah .....

More like:

def run():
while 1:
job = queue.get() # this blocks until something is queue.put()
_processjob(job )
Acquiring the locks isn't necessary and ill-advised. The Queue itself
can be thought of as a type of locking mechanism, so you raise the
possibility of a deadlock condition by nesting locks (for instance if
you also put locks around the queue.put()).

Regards,

--
Cliff Wells, Software Engineer
Logiplex Corporation (www.logiplex.net)
[phone] [phone]

[Graeme Matthew]

ok still a bit confused sorry .... first attempt at a thread pool

Am I correct in saying that each thread runs in a continious loop

each thread calls queue.get. The get method will block and not return
anything until an item is placed into it. When an item is placed into it,
one of the threads will get assinged a job i.e the first one that happens to
be in use during the cycle ?

The job is returned to the thread, it runs with the job and does all the
processing then returns and calls queue.get again and waits for a job to
become available ?

When placing a job via Queue.put() one must acquire a lock place it and then
release it

Am i aslo correct in saying that queue is actually doing the blocking and
controls which thread gets the job ?

Lastly, sorry for all the questions, surely the CPU usage is the same when
the queue is waiting for jobs and when the threads are polling as theyre all
in one process anyway

thanks very much for your help

Graeme
Am i getting this or am i way off :-)
"Graeme Matthew" <gs*******@ozem ail.com.au> wrote in message
news:ND******** *********@nnrp1 .ozemail.com.au ...

Aahz

Thanks, ive actually been using your OSCON slides which have helped a lot.
So it technically correct that all worker threads in a thread pool are
either doing some work or polling the queue to find out if there is a job
to process ?

eg: (pseudocodish :-))

def run(self):

while 1:

self.lock.acqui re()

if QueueManager.Ha sJob:
job = QueueManager.Ge tFreeJob()
__processJob(jo b)

self.lock.relea se()

def __processJob(se lf):

blah blah blah .....
many thanks ......
"Aahz" <aa**@pythoncra ft.com> wrote in message
news:bf******** **@panix1.panix .com...

In article <0t************ ****@nnrp1.ozem ail.com.au>,
Graeme Matthew <gs*******@ozem ail.com.au> wrote:

I just cannot seem to find any documentation that shows an example of
using the factory method Event() in threads. I have a thread pool and
if there are no jobs in a Queue I want them to wait for something to
be inserted. When a job is inserted I want to send an Event, the first
thread that picks it up runs with the job the rest wait for another
insert Event.

Given that you're already using a Queue, there is no, repeat NO, reason
for using an Event. Just have your threads block on the Queue.
--
Aahz (aa**@pythoncra ft.com) <*>

http://www.pythoncraft.com/

A: No.
Q: Is top-posting okay?

[Cliff Wells]

On Fri, 2003-07-18 at 18:29, Graeme Matthew wrote:

ok still a bit confused sorry .... first attempt at a thread pool

Am I correct in saying that each thread runs in a continious loop
Yes.
each thread calls queue.get. The get method will block and not return
anything until an item is placed into it. When an item is placed into
it, one of the threads will get assinged a job i.e the first one that
happens to be in use during the cycle ?
I think you have the idea, but I'm not sure (your terminology escapes me
a bit toward the end). What happens is each thread blocks waiting for
something to be placed on the queue. When something is put on the
queue, one of the available threads (i.e. one that is blocking on
queue.get() rather than processing a job). Only a single thread will be
woken for each item that is put on the queue. It isn't knowable which
thread that will be.
The job is returned to the thread, it runs with the job and does all
the processing then returns and calls queue.get again and waits for a
job to become available ?
Yes.
When placing a job via Queue.put() one must acquire a lock place it
and then release it
No. The locking semantics are internal to the Queue object. Do not
concern yourself with it. It simply works. Do not attempt to put locks
around it.
Am i aslo correct in saying that queue is actually doing the blocking
and controls which thread gets the job ?
In a sense (that is, for practical purposes). How it is done internally
by the interpreter isn't important.
Lastly, sorry for all the questions, surely the CPU usage is the same
when the queue is waiting for jobs and when the threads are polling as
theyre all in one process anyway
The threads are asleep while waiting. They don't consume any CPU. The
queue doesn't "wait" for jobs (that is, it doesn't loop, poll or
otherwise consume any CPU time), when you call queue.put() it is a
method call on an object, not a thread.
Am i getting this or am i way off :-)

Just a little way off ;)

Regards,

Cliff

--
My only regret is that I ever was born
-Swans

[Peter Hansen]

Graeme Matthew wrote:

ok so code like this is perfectly safe

def run(self):

while 1:

job = queue.get()

__processjob()

It's almost like you aren't even seeing Aahz' replies. ;-)

The above is certainly safe, but can't be terminated easily.
Just use the loop Aahz showed, which is the above plus the
ability to terminate.

-Peter

[Alan Kennedy]

Graeme Matthew wrote:

here is my code, please criticise it to death i wont take offence
[snip]
#ON A MULTIPLE CPU MACHINE 2 SEPERATE SERVERS SHOULD BE RUN
#THE INCOMING REQUEST WILL NEED TO BE SWITCHED BETWEEN SERVERS
#THIS IS DUE TO THE GLOBAL INTERPRETER LOCK (GIL) IN PYTHON

If my understanding of your intentions is correct, then I think you're
expecting that multiple python threads within the same interpreter
will migrate to multiple processors, and thus execute in parallel,
i.e. simultaneously on multiple processors.

However, the GIL prevents precisely that: if you have one python
thread running on one processor, it will lock the GIL, thus causing
all other python threads on other processors to be suspended until the
GIL is free again.

One way to achieve true concurrency across multiple processors is
to release the GIL when you are processing, which you cannot do from
within python code. You have to write a C language extension to do the
work, that releases the GIL before doing its job, and reacquires it
again when finished.

If you really want true concurrency, and still want to write in pure
python, then one way to do it is run multiple python interpreters in
separate OS processes, which are bound to different processors. Which
means that

1. You can no longer use Queue.Queue objects to communicate between
servers, since your servers no longer share an address space.

2. You have to use some alternate comms mechanism between the two
servers, such as shared memory, named pipes or something like Pyro.

3. You can no longer pass the socket object across wrapped in a "job"
object, since the file descriptor tables of the two server processes
will be different.

Lastly, I have a question of my own: I've read statements along the
lines of "having the GIL in python provides certain guarantees that
make certain things possible". I can't remember specifics. I'd be most
grateful if someone could point me to reading material (apart from the
source, Luke :-) which describes what these guarantees are, and what
they make possible.

TIA,

--
alan kennedy
-----------------------------------------------------
check http headers here: http://xhaus.com/headers
email alan: http://xhaus.com/mailto/alan