Очередь многопроцессорной обработки Python

Я заполняю очередь набором заданий, которые хочу запускать параллельно, и использую для этого модуль многопроцессорности python. Фрагмент кода ниже:

import multiprocessing
from multiprocessing import Queue
queue = Queue()
jobs = [['a', 'b'], ['c', 'd']]
for job in jobs:
    queue.put(job)

Когда я выполняю queue.get (), я получаю следующее:

['a', 'b']

Почему очередь не заполняется всеми заданиями?

5
задан Kaushik Balamukundhan 31 March 2011 в 20:55
поделиться