python进程间共享数据的方法是什么

126次阅读

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

在 Python 中，进程间共享数据的方法有以下几种：

使用 multiprocessing 模块中的 Value 和Array：Value用于共享一个单一的值，而 Array 用于共享一个数组，这两种方式都是基于共享内存的。

示例代码如下：

from multiprocessing import Process, Value, Array

def worker(num, arr):
    num.value = 10
    for i in range(len(arr)):
        arr[i] = i * i

if __name__ == '__main__':
    num = Value('i', 0)
    arr = Array('i', range(10))
    p = Process(target=worker, args=(num, arr))
    p.start()
    p.join()

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

使用 multiprocessing 模块中的 Manager：Manager 可以创建一个共享数据的服务器进程，然后其他进程可以通过代理对象来访问共享数据。

示例代码如下：

from multiprocessing import Process, Manager

def worker(dict_data, list_data):
    dict_data['key'] = 'value'
    list_data.append(10)

if __name__ == '__main__':
    with Manager() as manager:
        dict_data = manager.dict()
        list_data = manager.list()

        p = Process(target=worker, args=(dict_data, list_data))
        p.start()
        p.join()

        print(dict_data)
        print(list_data)

使用 multiprocessing 模块中的 Queue：Queue 是一种先进先出的数据结构，多个进程可以通过 Queue 互相传递数据。

示例代码如下：

from multiprocessing import Process, Queue

def worker(q):
    q.put('Hello World')

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

    p = Process(target=worker, args=(q,))
    p.start()
    p.join()

    print(q.get())

总的来说，multiprocessing模块提供了多种方式来实现进程间的数据共享，可以根据具体的需求选择合适的方法。

丸趣 TV 网 – 提供最优质的资源集合！

正文完