python多进程怎么共享数据

44次阅读

共计 1352 个字符，预计需要花费 4 分钟才能阅读完成。

在 Python 中，多进程之间可以通过以下几种方式共享数据：

共享内存：使用 multiprocessing.Value 和multiprocessing.Array可以创建共享内存的变量和数组。这些共享变量和数组可以在多个进程之间进行读写操作。

from multiprocessing import Process, Value, Array

def update_value(v):
    v.value += 1

def update_array(a):
    for i in range(len(a)):
        a[i] += 1

if __name__ == '__main__':
    v = Value('i', 0)
    a = Array('i', [0, 1, 2, 3, 4])

    p1 = Process(target=update_value, args=(v,))
    p2 = Process(target=update_array, args=(a,))

    p1.start()
    p2.start()

    p1.join()
    p2.join()

    print(v.value)  # 输出: 1
    print(a[:])  # 输出: [1, 2, 3, 4, 5]

管道（Pipe）：使用 multiprocessing.Pipe 可以创建进程之间的管道，并通过管道发送和接收数据。

from multiprocessing import Process, Pipe

def send_data(conn):
    conn.send("Hello from child process!")

def receive_data(conn):
    data = conn.recv()
    print(data)

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()

    p1 = Process(target=send_data, args=(child_conn,))
    p2 = Process(target=receive_data, args=(parent_conn,))

    p1.start()
    p2.start()

    p1.join()
    p2.join()

共享队列（Queue）：使用 multiprocessing.Queue 可以创建进程之间的队列，并通过队列发送和接收数据。

from multiprocessing import Process, Queue

def send_data(q):
    q.put("Hello from child process!")

def receive_data(q):
    data = q.get()
    print(data)

if __name__ == '__main__':
    q = Queue()

    p1 = Process(target=send_data, args=(q,))
    p2 = Process(target=receive_data, args=(q,))

    p1.start()
    p2.start()

    p1.join()
    p2.join()