在多进程编程中,进程之间需要进行通信,以实现数据共享、协作计算等功能。而进程间通信(IPC,Inter-Process Communication)是实现这些功能的重要手段。Python提供了多种进程间通信方式,包括管道、共享内存、消息队列、信号量等。
管道是一种进程间通信方式,它是一条单向通道,可以在两个进程之间传递数据。在Python中,可以使用multiprocessing模块中的Pipe类来创建管道。
下面是一个使用管道实现多进程通信的示例代码:
import multiprocessing
def sender(conn):
conn.send('hello')
conn.close()
def receiver(conn):
msg = conn.recv()
print('received:', msg)
conn.close()
if __name__ == '__main__':
parent_conn, child_conn = multiprocessing.Pipe()
p1 = multiprocessing.Process(target=sender, args=(parent_conn,))
p2 = multiprocessing.Process(target=receiver, args=(child_conn,))
p1.start()
p2.start()
p1.join()
p2.join()
这里我们定义了两个进程函数sender和receiver,分别用于发送和接收数据。在主程序中,我们创建了一个管道parent_conn和child_conn,分别用于父进程和子进程之间的通信。然后创建了两个进程p1和p2,分别将sender和receiver函数作为进程的执行函数。在进程p1中,我们通过管道发送了一条消息“hello”;在进程p2中,我们通过管道接收了这条消息,并打印出来。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。