🚀 go-pugleaf

On Feb 25, 5:52 pm, Slawomir Piasecki <piase...@gmail.com> wrote:
> 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.
Robisz:
p = Process(target=f, args=(q, dat)).start()

Metoda start() nie zwraca obiektu na którym została wywołana, tylko
None (bo to procedura). Powinno być:

p = Process(target=f, args=(q, dat))
p.start()

PS. "if i.is_alive() is False:" bym zamienił na  "if not
process.is_alive():" - jakoś tak bardziej czytelnie. Zastanowiłbym się
też nad faktem, że aktualnie właściwie robisz aktywne oczekiwanie. Z
opóźnieniem 5 sekund, ale zawsze.