Что нужно использовать для обмена данными между процессами
Python
Junior
Без компании
Что нужно использовать для обмена данными между процессами
Ответы
Для обмена данными между процессами в Python можно использовать несколько подходов:
- **multiprocessing.Queue** - потокобезопасная очередь:
```
from multiprocessing import Process, Queue
def worker(q):
q.put('Hello from child')
q = Queue()
p = Process(target=worker, args=(q,))
p.start()
print(q.get()) # Получаем данные
p.join()
```
- **Pipe** - двунаправленный канал:
```
from multiprocessing import Pipe, Process
def worker(conn):
conn.send('Message')
conn.close()
parent_conn, child_conn = Pipe()
p = Process(target=worker, args=(child_conn,))
p.start()
print(parent_conn.recv()) # Получаем сообщение
p.join()
```
- **Shared Memory** (Value/Array) - для числовых данных:
```
from multiprocessing import Process, Value
def worker(n):
n.value += 1
num = Value('i', 0)
p = Process(target=worker, args=(num,))
p.start()
p.join()
print(num.value) # Выведет 1
```
Выбор зависит от задачи: Queue для сложных объектов, Pipe для двунаправленного обмена, Shared Memory для производительности с примитивными типами.