python多進(jìn)程怎么共享數(shù)據(jù)

153次閱讀

共計(jì) 1352 個(gè)字符，預(yù)計(jì)需要花費(fèi) 4 分鐘才能閱讀完成。

在 Python 中，多進(jìn)程之間可以通過以下幾種方式共享數(shù)據(jù)：

共享內(nèi)存：使用 multiprocessing.Value 和multiprocessing.Array可以創(chuàng)建共享內(nèi)存的變量和數(shù)組。這些共享變量和數(shù)組可以在多個(gè)進(jìn)程之間進(jìn)行讀寫操作。

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 可以創(chuàng)建進(jìn)程之間的管道，并通過管道發(fā)送和接收數(shù)據(jù)。

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()

共享隊(duì)列（Queue）：使用 multiprocessing.Queue 可以創(chuàng)建進(jìn)程之間的隊(duì)列，并通過隊(duì)列發(fā)送和接收數(shù)據(jù)。

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()