while True:
    item = QUEUE.get()
print('Process %s has done: %s' % (consumer_id, item))
QUEUE.task_done()
p = Process(target=generator)
p.start()
for x in range(0, 2):
    w = Process(target=consumer, args=(x,))
w.start()
p.join()
w.join()
Django - как настроить асинхронную длительную задачу фоновой обработки данных?