warum die Warteschlange für die Kommunikation in diesem Multiprozess-Fall nicht funktioniert

Question

Der folgende Code bezieht sich auf die Kommunikation zwischen zwei untergeordneten Prozessen durch die Warteschlange. Ich kann nicht herausfinden, warum die self.q.qsize() Null ist und self.q.get() ist in der Funktion "ACT" blockiert .... .... Da der Zähler zeigt, ist die Warteschlange voll. ..

#!/usr/bin/env python 
# -*- coding: utf-8 -*- 

from multiprocessing import Process 
import multiprocessing 
import time 
from Queue import Queue 

class Test(): 
    def __init__(self): 
     self.q = Queue(1) 

    def ACT(self): 
     while True: 
      print "B momoent queue size: %s" %self.q.qsize() 
      print self.q.get() 
      time.sleep(1) 

    def counter(self): 
     for i in range(5,10): 
      if not i == 5: 
       print "Hello1" 
      print self.q.full() 
      self.q.join() 
      print "Hello2" 
      self.q.put(str(i)) 
      print "A moment queue size: %s" % self.q.qsize()   
if __name__ == '__main__': 

    foo = Test() 
    qw = Process(target=foo.counter) 
    qw.start() 

    qr = Process(target=foo.ACT) 
    qr.start() 

    qw.join() 
    print "End" 

Answer 1

Sie müssen multiprocessing.Queue verwenden.

Queue.Queue ist für die Verwendung von Threads gedacht. Derzeit erstellen und verwenden Sie separate Warteschlangeninstanzen in jedem Prozess. Es gibt keine Logik, die die Kommunikation zwischen Prozessen erleichtert, die multiprocessing.Queue bietet.

multiprocessing.Queue Spiegel meisten Queue.Queue Methoden, aber Sie werden join Methodenaufruf und möglicherweise qsize wenn auf OS X.