このマルチプロセスの場合、キューが通信に使用できない理由

Question

次のコードは、2つの子プロセス間の通信をキュー単位で示したものです。 self.q.qsize（）がゼロで、self.q.get（）が "ACT"関数でブロックされているのはなぜですか？....カウンタはキューがいっぱいであることを示しています。 ..

#!/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

multiprocessing.Queueを使用する必要があります。

Queue.Queueは、スレッディング用です。現在、各プロセスに別々のキューインスタンスを作成して使用しています。multiprocessing.Queueが提供するプロセス間通信を容易にするロジックはありません。

multiprocessing.QueueミラーQueue.Queue方法のほとんどが、あなたがあればOS Xの