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 stm32f407使用DMA问题
  • ¥15 您好 这个API接口该怎么弄 网站搭建好了 API也有 现在就不知道该怎么填写API 不知道怎么用
  • ¥88 用uniapp写一个多端的程序,用到高德地图,用高德的JSAPI吗?
  • ¥20 关于#c++#的问题:水果店管理系统
  • ¥30 dbLinq最新版linq sqlite
  • ¥20 对D盘进行分盘之前没有将visual studio2022卸载掉,现在该如何下载回来
  • ¥15 完成虚拟机环境配置,还有安装kettle
  • ¥15 2024年全国大学生数据分析大赛A题:直播带货与电商产品的大数据分析 问题5. 请设计一份优惠券的投放策略,需要考虑优惠券的数量、优惠券的金额、投放时间段和投放商品种类等因素。求具体的python代码
  • ¥15 有人会搭建生鲜配送自营+平台的管理系统吗
  • ¥15 用matlab写代码