Python进程间通信方式

当前位置:

首页 > Python基础教程 >

Python进程间通信方式

当然，我可以为你提供几个Python进程间通信方式的示例代码。由于篇幅限制，我将分别展示使用`multiprocessing`模块中的`Pipe`、`Queue`和`Value`/`Array`的简单示例。

### 示例1：使用Pipe

from multiprocessing import Process, Pipe

def sender(conn):
    conn.send(['hello', 'world', None, 'python'])
    conn.close()

def receiver(conn):
    while True:
        print(conn.recv())
        if conn.poll() is None:
            break
    conn.close()

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()
    p = Process(target=sender, args=(child_conn,))
    q = Process(target=receiver, args=(parent_conn,))
    p.start()
    q.start()
    p.join()
    q.join()

注意：`Pipe`示例中的`receiver`函数中的`while True`和`if conn.poll() is None:`可能不是处理`Pipe`消息的最佳方式，因为`Pipe`在发送`None`或`EOF`（文件结束符）时并不自动关闭连接。这里只是为了演示如何接收消息而编写的简单循环。在实际应用中，你可能需要一种更明确的结束信号或条件。

### 示例2：使用Queue

from multiprocessing import Process, Queue

def writer(q):
    for value in ['Foo', 'Bar', None]:
        q.put(value)

def reader(q):
    while True:
        value = q.get()
        if value is None:
            break
        print(value)

if __name__ == '__main__':
    q = Queue()
    pw = Process(target=writer, args=(q,))
    pr = Process(target=reader, args=(q,))
    pw.start()
    pr.start()
    pw.join()
    q.put(None) # 发送结束信号
    pr.join()

### 示例3：使用Value和Array共享内存

from multiprocessing import Process, Value, Array

def f(n, a):
    n.value = 3.1415927
    for i in range(len(a)):
        a[i] = -a[i]

if __name__ == '__main__':
    num = Value('d', 0.0) # 创建一个double类型的共享内存
    arr = Array('i', range(10)) # 创建一个整型数组（类似C语言中的数组）

    p = Process(target=f, args=(num, arr))
    p.start()
    p.join()

    print(num.value)
    print(arr[:])

这些示例展示了如何在Python中使用`multiprocessing`模块进行进程间通信。注意，由于`multiprocessing`模块设计用于跨平台，因此这些示例在Windows、Linux和macOS上都应该能够正常工作。然而，具体的行为（如进程和主程序的结束时机）可能会因操作系统和Python解释器的具体实现而有所不同。

最后，如果你对python语言还有任何疑问或者需要进一步的帮助，请访问https://www.xin3721.com 本站原创，转载请注明出处：https://www.xin3721.com/Python/python50242.html

栏目列表