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

Question

[Max Payne]

Возникла такая идея:
У нас есть основной процесс программы, создаётся дочерний -- в материнском процессе бесконечный цикл который отправляет какие-то данные дочернему не дожидаясь ответа. Как это правильно реализовать? В какую сторону смотреть?
Я пробовал это реализовать через Popen и PIPE ( в качестве stdin и stdout ) и посылать туда запросы через Popen.communicate, но это не сработало, увы, так как communicate ожидает завершения и выводит результат, чего мне не нужно.

P.S. Увы, в многопоточности я не так хорош, как в подборе тегов для вопроса, поэтому не обессудьте.

UPD1
Надумал что-то такое:
main.py

import subprocess
p = subprocess.Popen(['python', 'test1.py'], stdin=subprocess.PIPE)
p.stdin.write(bytes('test1', 'UTF-8'))

test1.py

import sys
f = open('f.txt', 'w+')
f.write(sys.stdin.read()) # f.write(str(sys.stdin.read(), 'UTF-8')) тоже не работает
f.close()

Но это не работает, что не удивительно. Файл всегда пуст.

Answer 1

[Max Payne]

В общем я решил отказаться от этой идеи и использовал сокеты.
client.py получает данные, обрабатывает и отправляет через сокет, server.py все это время слушает канал.

UPD 11.08.2017
А ещё лучше, как оказалось, использовать multiprocessing.Manager

Answer 2

[lega]

https://docs.python.org/2/library/multiprocessing....

Comments

[Max Payne]

Видел это -- не понимаю как это работает и зачем мне это нужно.

[lega]

Arti Markelov: Это позволяет запустить дочерний процесс и сделать простую коммуникацию между ними (send/recv, put/get), то что вы пытаетесь сделать.

Но практичней взять zmq/rabbitmq/mongodb/redis и т.п. это позволит запустить процессы на разных серверах и ещё + куча плюшек.

[Max Payne]

lega: Queue очереди это интересно, но не особо понимаю как внутрь очереди повесить обработчик, который бы выполнял функцию. То есть хорошо, пускай у нас есть цикл бесконечный который загружает какие-то данные в очередь queue, но (в идеале) в другом процессе мне нужно их получить и выполнить действие.

[Max Payne]

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