首页 > 解决方案 > 多处理方法按顺序工作

问题描述

作业函数接受输入字符串(id)、DataFrame、return_dict

def job(sid, df, return_dict):

    print("Process Started")
    #.... method body ....#
    print("Saving Data !!")
    df_out.to_csv(f'{sid}.csv', index=False)

    return_dict[Doc] = df_out

if __name__ == '__main__':

    df = pd.read_csv('data/data.csv')

    manager = mp.Manager()
    return_dict = manager.dict()

    p1 = mp.Process(target=job, args=['id_1', df, return_dict])
    p2 = mp.Process(target=job, args=['id_2', df, return_dict])

    p1.start()
    p2.start()

    p1.join()
    p2.join()

方法输出

Process Started
Saving Data !!
Process Started
Saving Data !!

用顺序方式......应该是那样的!

Process Started
Process Started
Saving Data !!
Saving Data !!

标签: pythonmultiprocessingpython-multiprocessing

解决方案


推荐阅读