Какие знаешь способо передачи данных между процессами в Python

Question

Young&Junior · Accepted Answer

В Python есть несколько способов передачи данных между процессами:

1. **Очереди (Queue)** – потокобезопасный способ обмена данными. 
from multiprocessing import Queue, Process

def worker(q):
 q.put("Hello from child!")

q = Queue()
p = Process(target=worker, args=(q,))
p.start()
print(q.get()) # "Hello from child!"
p.join()

2. **Каналы (Pipe)** – двунаправленное соединение между процессами. 
from multiprocessing import Pipe, Process

def worker(conn):
 conn.send("Data from child")
 conn.close()

parent_conn, child_conn = Pipe()
p = Process(target=worker, args=(child_conn,))
p.start()
print(parent_conn.recv()) # "Data from child"
p.join()

3. **Разделяемая память (Value, Array, shared_memory)** – для числовых данных. 
from multiprocessing import Process, Value

def increment(shared_num):
 shared_num.value += 1

num = Value('i', 0)
p = Process(target=increment, args=(num,))
p.start()
p.join()
print(num.value) # 1

4. **Серверные процессы (Manager)** – для сложных структур (списки, словари). 
from multiprocessing import Manager, Process

def worker(shared_list):
 shared_list.append(1)

with Manager() as manager:
 lst = manager.list()
 p = Process(target=worker, args=(lst,))
 p.start()
 p.join()
 print(lst) # [1]

Выбор зависит от типа данных и требований к производительности.

Похожие вопросы