python 多进程问题

Question

python 三个进程之间的通信如何实现，比如两个进程里各有一个参数，发送给另一个进程，如何实现。求解答

Answer 1

进程间通讯手段有很多，比如管道、队列、信号量、共享内存、事件、条件、锁等。猜测题主的需求，大约使用共享内存即可解决。multiprocessing 模块提供了 Value 和 Array 两个共享内存对象，一个用于单值共享，一个用于数组共享。实例化 Value 和 Array 时，'d' 表示双精度浮点数，'i' 表示有符号整数。这些共享对象是进程和线程安全的。

下面的代码演示了两个进程如何共享单值内存和数组内存。若共享单值为 0，则进程 A 对共享数组的元素加 2，同时置共享单值为 1；若共享单值为 1，则进程 B 对共享数组的元素减 1，同时置共享单值为 0。这个例子里面隐式地涉及了 ctypes 模块，这是一个用于在 Python 和C 或 C++ 之间架设沟通桥梁的模块。

# -*- coding: utf-8 -*-

"""
《Python高手修炼之路》
3.9.3 进程间通信——共享内存
"""

import os, time
import multiprocessing as mp

def sub_process_A(flag, data):
    """A进程函数"""
    
    while True:
        if flag.value == 0: # 若标志为0
            time.sleep(1)
            for i in range(len(data)): # 共享数组各元素加2
                data[i] += 2
            flag.value = 1 # 置标志为1
            print([item for item in data])

def sub_process_B(flag, data):
    """B进程函数"""
    
    while True:
        if flag.value == 1: # 若标志为0
            time.sleep(1)
            for i in range(len(data)):
                data[i] -= 1 # 共享数组各元素减1
            flag.value = 0 # 置标志为0
            print([item for item in data])

if __name__ == '__main__':
    print('主进程（%s）开始，按回车键结束本程序'%os.getpid())
    
    flag = mp.Value('i', 0) # flag类型是ctypes.c_long，不是普通的int
    data = mp.Array('d', range(5))
    
    p_a = mp.Process(target=sub_process_A, args=(flag, data))
    p_a.daemon = True
    p_a.start()
    
    p_b = mp.Process(target=sub_process_B, args=(flag, data))
    p_b.daemon = True
    p_b.start()
        
    input()