Сбрасывание многопроцессорности.

Я хочу сбросить multiprocessing.Queue в список. Для этой задачи я написал следующую функцию:

 import Queue def dump_queue(queue): """ Empties all pending items in a queue and returns them in a list. """ result = [] # START DEBUG CODE initial_size = queue.qsize() print("Queue has %s items initially." % initial_size) # END DEBUG CODE while True: try: thing = queue.get(block=False) result.append(thing) except Queue.Empty: # START DEBUG CODE current_size = queue.qsize() total_size = current_size + len(result) print("Dumping complete:") if current_size == initial_size: print("No items were added to the queue.") else: print("%s items were added to the queue." % \ (total_size - initial_size)) print("Extracted %s items from the queue, queue has %s items \ left" % (len(result), current_size)) # END DEBUG CODE return result 

Но по какой-то причине это не сработает.

• многопроцессор python - процесс зависает при соединении для большой очереди
• Выполнение задач параллельно в python
• многопроцессор python: запись в один файл excel
• Как конвертировать 'из очереди импорта очереди, пустым' из Python 2 в Python 3?
• Как передать ссылку на очередь на функцию, управляемую пулом.map_async ()?

Соблюдайте следующий сеанс оболочки:

 >>> import multiprocessing >>> q = multiprocessing.Queue() >>> for i in range(100): ... q.put([range(200) for j in range(100)]) ... >>> q.qsize() 100 >>> l=dump_queue(q) Queue has 100 items initially. Dumping complete: 0 items were added to the queue. Extracted 1 items from the queue, queue has 99 items left >>> l=dump_queue(q) Queue has 99 items initially. Dumping complete: 0 items were added to the queue. Extracted 3 items from the queue, queue has 96 items left >>> l=dump_queue(q) Queue has 96 items initially. Dumping complete: 0 items were added to the queue. Extracted 1 items from the queue, queue has 95 items left >>> 

Что тут происходит? Почему не все предметы сбрасываются?

 import Queue import time def dump_queue(queue): """ Empties all pending items in a queue and returns them in a list. """ result = [] for i in iter(queue.get, 'STOP'): result.append(i) time.sleep(.1) return result import multiprocessing q = multiprocessing.Queue() for i in range(100): q.put([range(200) for j in range(100)]) q.put('STOP') l=dump_queue(q) print len(l) 

 shared_queue = Queue() shared_queue_list = [] ... join() #All process are joined while shared_queue.qsize() != 0: shared_queue_list.append(shared_queue.get())