Что использовать для оперативной передачи данных между процессами в python?

>multiprocessing
>поток

использую from multiprocessing import Process, Queue, Lock

Если я правильно понял, тебе нужен менеджер https://docs.python.org/3.6/library/multiprocessing.html#multiprocessing-mana...

Нахуй там lock? В queue нинужно lock.

как мне получить все элементы очереди в массив? в доках сказано - get из очереди в цикле. а это - очистка очереди. следовательно, нужно воссоздать. от этого и lock

как его юзать правильно?

как мне получить все элементы очереди в массив? в доках сказано - get из очереди в цикле.

Ага.

следовательно, нужно воссоздать

Кого и зачем нужно воссоздать?

Моя чует, тебе нужно выспаться и shared memory. Но вначале выспаться.

что он хочет?

Process SendMailWorker-3:
Traceback (most recent call last):
  File "C:\python\lib\multiprocessing\managers.py", line 749, in _callmethod
    conn = self._tls.connection
AttributeError: 'ForkAwareLocal' object has no attribute 'connection'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "C:\python\lib\multiprocessing\process.py", line 249, in _bootstrap
    self.run()
  File "C:\dev\my\mailsender\src\MailSender\Engine\Worker.py", line 33, in run
    self.work()
  File "C:\dev\my\mailsender\src\MailSender\Engine\Workers\SendMailWorker.py", line 91, in work
    TaskListEntry.id.notin_(ids) if (len(ids) > 0) else True
  File "<string>", line 2, in __len__
  File "C:\python\lib\multiprocessing\managers.py", line 753, in _callmethod
    self._connect()
  File "C:\python\lib\multiprocessing\managers.py", line 740, in _connect
    conn = self._Client(self._token.address, authkey=self._authkey)
  File "C:\python\lib\multiprocessing\connection.py", line 485, in Client
    c = PipeClient(address)
  File "C:\python\lib\multiprocessing\connection.py", line 686, in PipeClient
    _winapi.WaitNamedPipe(address, 1000)
FileNotFoundError: [WinError 2] Не удается найти указанный файл

FileNotFoundError: [WinError 2] Не удается найти указанный файл

Установи нормальную операционную систему вместо винды

да ладно тебе. что есть под рукой. питон же кроссплатформенный, не?

это, похоже, баг с 2008 года тянется https://bugs.python.org/issue3419

Так, похоже, разобрался. В моем классе-менеджере всех воркеров я создаю multiprocessing.Manager(), от которого - dict() (анонимус, это и есть shared memory?). После я стартовал всех воркеров, но не делал join(). Пишут, что в такой ситуации этот процесс завершается, закрыв соединение Manager-а, поэтому такая ошибка и возникает на стороне воркеров. Сделал

for w in self.workers :
   w.join()

Хотел предложить сервер поверх удс использовать (ибо оверхед минимален, компоненты из коробки, расширяемость на будущее), но винда жеж)