🚀 go-pugleaf

ok wiec multiprocess, poczytalem troche dokumentacji i troche
tutoriali
i postanowilem wypisac wstepnie maly programik:

[code]
def f(q, n):
    for i in range(2,4):
      t = i * n

      if t < 100:
        print "dodaje ", t
        q.put(t) # dodaj do kolejki

def run(nrStart):
     q = Queue()

     for i in range(nrStart):
       q.put(i) # dodaj do kolejki

     nr = 2
     pula = []

     while True:
       for i in pula:
         if i.is_alive() is False:
           pula.remove(i) # usun z puli jesli juz wykonany

       while len(pula) < nr:
           if q.qsize() > 0:
             dat = q.get() # pobierz z kolejki
             print "startuje ", dat
             p = Process(target=f, args=(q, dat)).start() # wystartuj
z procesem
             pula.append(p) # dodaj do puli

           else:
             if len(pula) == 0:
               return # zakoncz
             else:
               break # wroc do petli

       sleep(5) # czekaj

if __name__ == '__main__':
 run(5)

[/code]

i dostaje po odpaleniu komunikat:
  File "tst.py", line 28, in run
    if i.is_alive() is False:
AttributeError: 'NoneType' object has no attribute 'is_alive'
Exception in thread QueueFeederThread (most likely raised during
interpreter shutdown):
Traceback (most recent call last):
  File "/usr/lib/python2.6/threading.py", line 522, in
__bootstrap_inner
  File "/usr/lib/python2.6/threading.py", line 477, in run
  File "/usr/lib/python2.6/multiprocessing/queues.py", line 233, in
_feed
<type 'exceptions.TypeError'>: 'NoneType' object is not callable

wiec tutaj sie blokuje i nie wiem jak sprawdzic czy dany process jesce
dziala czy nie,

pozdrawiam
p.s.