Message101756
Firstly I think as you but this is not correct.
Added Q.full() to know if Queue is full or not to the testQ code..
def testQ():
for i in range(10000):
mp.Process( None, QueueWorker, None, (i,Q,lock) ).start()
while len(mp.active_children())>=mp.cpu_count()+4:
time.sleep(0.01)
print Q.full()
output is:
1397 done
1398 done
1399 done
False
False
False
So Queue is not full. And you can also add some things to queue at this state(by adding extra line to while loop) and this will not blocks while loop.
Please test.. |
|
Date |
User |
Action |
Args |
2010-03-26 16:11:05 | eua | set | recipients:
+ eua, jnoller, r.david.murray |
2010-03-26 16:11:05 | eua | set | messageid: <1269619865.36.0.41884883067.issue8237@psf.upfronthosting.co.za> |
2010-03-26 16:11:03 | eua | link | issue8237 messages |
2010-03-26 16:11:03 | eua | create | |
|