timmy / 使用 multiprocessing.Pipe 進行進程間通訊
0 вподобань
0 форк(-ів)
1 файл(-ів)
Остання активність 9 months ago
multiprocessing.Pipe 允許 Python 進程之間傳遞資料，適用於需要高效能、雙向通訊的場景，如併發運算或分佈式處理。
| 1 | from multiprocessing import Process, Pipe |
| 2 | |
| 3 | def worker(conn): |
| 4 | conn.send("Hello from child process") # 傳送訊息 |
| 5 | msg = conn.recv() # 接收訊息 |
| 6 | print(f"Child received: {msg}") |
| 7 | conn.close() |
| 8 | |
| 9 | if __name__ == "__main__": |
| 10 | parent_conn, child_conn = Pipe() # 建立 Pipe 雙向通道 |
Новіше
Пізніше