Как использовать многопроцессорную очередь в Python?

У меня большие проблемы с попыткой понять, как многопроцессорная очередь работает на python и как ее реализовать. Допустим, у меня есть два модуля Python, которые получают доступ к данным из общего файла, назовем эти два модуля записывающим и читающим. Мой план состоит в том, чтобы и читатель, и писатель помещали запросы в две отдельные многопроцессорные очереди, а затем заставляли третий процесс помещать эти запросы в цикл и выполнять их как таковые.

Моя основная проблема заключается в том, что я действительно не знаю, как правильно реализовать multiprocessing.queue, вы не можете создать экземпляр объекта для каждого процесса, поскольку они будут отдельными очередями, как вы убедитесь, что все процессы связаны с общей очередью (или в данном случае очереди)

68
задан jab 17 July 2012 в 04:17
поделиться