1

multiprocessing モジュールを使用した次のコード スニペットがあります。

import time

from multiprocessing import Process, Queue

q = Queue()

def feeder():
    x=0
    while True:
       q.put(x)
       time.sleep(1)
       x+=1

p=Process(target=feeder).start()

while True:
    print q.get()

q.get新しいデータがキューに到着すると、毎秒印刷するようになりました。q.getリターン (つまり、エラーを発生させるか、None を返すか、またはその他の方法による) をできるだけ早くしたいと思います。

4

1 に答える 1

1

のドキュメント.getを読みましたか?

while True:
    try:
        print q.get(block=False)  # or q.get_nowait()
    except Queue.Empty:
        pass
于 2013-09-16T12:10:13.463 に答える