page contents

进程间通信(IPC)在Python中的方式有哪些?

在项目里只要一涉及到多进程,大家八成就会想到一个问题:这些进程要怎么“说话”?这其实就是进程间通信(IPC, Inter-Process Communication)。在 Python 里,标准库 multiprocessing 已经帮我们准备好了好几种方式。下面我就按常见的几种聊一下,顺带贴点代码,大家能对比着理解。

attachments-2025-09-87aRFhNF68c8bc1183286.png在项目里只要一涉及到多进程,大家八成就会想到一个问题:这些进程要怎么“说话”?这其实就是进程间通信(IPC, Inter-Process Communication)。在 Python 里,标准库 multiprocessing 已经帮我们准备好了好几种方式。下面我就按常见的几种聊一下,顺带贴点代码,大家能对比着理解。

管道(Pipe

管道就像一根电话线,分为两头。一个进程往里写,另一个进程能收到。

from multiprocessing import Process, Pipe

def worker(conn):
    msg = conn.recv()
    print("子进程收到:", msg)
    conn.send("好的,收到!")

if __name__ == "__main__":
    parent_conn, child_conn = Pipe()
    p = Process(target=worker, args=(child_conn,))
    p.start()

    parent_conn.send("你好啊")
    print("主进程收到:", parent_conn.recv())
    p.join()

这种方式很适合一对一的通信,但要多个进程一起用,就得小心设计,不然容易乱。

队列(Queue

队列就更像个“公共信箱”。大家都可以往里面投信,也都能去取。内部实现是安全的(有锁),所以不用担心抢数据的问题。

from multiprocessing import Process, Queue

def worker(q):
    q.put("子进程写的数据")

if __name__ == "__main__":
    q = Queue()
    p = Process(target=worker, args=(q,))
    p.start()
    print("主进程收到:", q.get())
    p.join()

队列特别适合生产者—消费者这种模式,一个进程负责丢任务,另一些进程来取。

共享内存(Value, Array)

如果你嫌传来传去慢,可以让进程直接看同一块内存。比如一个共享的数值或者数组:

from multiprocessing import Process, Value

def worker(num):
    num.value += 1

if __name__ == "__main__":
    num = Value('i'0)  # 'i' 表示int类型
    processes = [Process(target=worker, args=(num,)) for _ in range(5)]

    for p in processes: p.start()
    for p in processes: p.join()

    print("结果:", num.value)  # 5

这种方式效率高,但得注意同步问题,不然会出现数据错乱。

Manager

有时候我们想共享的不只是简单的值或数组,而是字典、列表这种更复杂的对象。这个时候可以用 multiprocessing.Manager()。它内部会起一个服务进程来管理对象。

from multiprocessing import Process, Manager

def worker(shared_dict):
    shared_dict["count"] = shared_dict.get("count"0) + 1

if __name__ == "__main__":
    with Manager() as manager:
        shared_dict = manager.dict()
        processes = [Process(target=worker, args=(shared_dict,)) for _ in range(3)]

        for p in processes: p.start()
        for p in processes: p.join()

        print("最终结果:", shared_dict)

这就像大家都去找一个管理员,把数据更新上去,然后别人也能看到。

整体来说,管道和队列适合消息传递,共享内存和 Manager适合数据共享。实际用的时候要根据场景来选,比如任务分发一般用队列,计数器这类就用共享内存。

更多相关技术内容咨询欢迎前往并持续关注好学星城论坛了解详情。

想高效系统的学习Python编程语言,推荐大家关注一个微信公众号:Python编程学习圈。每天分享行业资讯、技术干货供大家阅读,关注即可免费领取整套Python入门到进阶的学习资料以及教程,感兴趣的小伙伴赶紧行动起来吧。

attachments-2022-05-rLS4AIF8628ee5f3b7e12.jpg

你可能感兴趣的文章

相关问题

0 条评论

请先 登录 后评论
Pack
Pack

1368 篇文章

作家榜 »

  1. 轩辕小不懂 2403 文章
  2. 小柒 2200 文章
  3. Pack 1370 文章
  4. Nen 576 文章
  5. 王昭君 209 文章
  6. 文双 71 文章
  7. 小威 64 文章
  8. Cara 36 文章