qq_40170374 2021-04-05 12:57 采纳率: 100%
浏览 43
已采纳

请教python multiprocessing的问题

main.py

import multiprocessing.pool as Pool
from test import set_data, get_multiprocessing



if __name__ == '__main__':
    data_list = ['data1', 'data2', 'data3']
    set_data(data_list)
    res = get_multiprocessing(2)
    print(res)

test.py

import time
import multiprocessing

_t = None

def set_data(t):
    time.sleep(1)
    global _t
    _t = t

def get_data(idx):

    return _t[idx]

def get_multiprocessing(num_threads):
    pool = multiprocessing.Pool(processes=num_threads)
    res = pool.map(get_data, range(1))
    pool.close()
    pool.join()

    return [r for r in res]

我想要等这个全局变量赋值之后再进行多进程,有什么办法吗?

向大佬们请教

  • 写回答

1条回答 默认 最新

  • 天元浪子 Python领域优质创作者 2021-04-05 15:44
    关注

    和线程不同,进程间不能共享全局变量,也不共享对象,进程间只能通过共享内存、管道、信号量、事件等手段通讯。如果题主一定要进程间共享这个全局变量,恐怕只能像下面的代码一样将全局变量作为参数传进去——这已经不是共享对象,而是副本传参了。

    import time
    import multiprocessing as mp
    
    _t = None
    
    def set_data(t):
        time.sleep(1)
        global _t
        _t = t
    
    def get_data(arg):
        arr, idx = arg
        return arr[idx]
    
    def get_multiprocessing(num_threads):
        pool = mp.Pool(processes=num_threads)
        res = pool.map(get_data, ((_t,0),(_t,1),(_t,2)))
        pool.close()
        pool.join()
    
        return list(res)
    
    if __name__ == '__main__':
        data_list = ['data1', 'data2', 'data3']
        set_data(data_list)
        res = get_multiprocessing(2)
        print(res)
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 依据报错在原代吗格式的基础上解决问题
  • ¥15 在虚拟机中安装flash code
  • ¥15 单片机stm32f10x编写光敏电阻调节3.3伏大功率灯亮度(光强越大灯越暗,白天正常光强灯不亮,使用ADC,PWM等模块)望各位找一下错误或者提供一个可实现功能的代码
  • ¥20 verilog状态机方法流水灯
  • ¥15 pandas代码实现不了意图
  • ¥15 GD32H7 从存储器到外设SPI传输数据无法重复启用DMA
  • ¥25 LT码在高斯信道下的误码率仿真
  • ¥45 渲染完成之后将物体的材质贴图改变,自动化进行这个操作
  • ¥15 yolov5目标检测并显示目标出现的时间或视频帧
  • ¥15 电视版的优酷可以设置电影连续播放吗?