当前位置: 代码网 > it编程>前端脚本>Python > python多进程实现数据共享的示例代码

python多进程实现数据共享的示例代码

2025年01月16日 Python 我要评论
背景安卓ui自动化框架,使用的是多进程实现的多设备并行。而在捞取数据做数据汇总时,需要多进程可以数据共享。进程、进程创建程序编写完没有运行称之为程序。正在运行的代码就是进程。在python3语言中,对

背景

 安卓ui自动化框架,使用的是多进程实现的多设备并行。而在捞取数据做数据汇总时,需要多进程可以数据共享。

进程、进程创建

程序编写完没有运行称之为程序。正在运行的代码就是进程。在python3语言中,对多进程支持的是multiprocessing模块和subprocess模块。multiprocessing模块为在子进程中运行任务、通讯和共享数据,以及执行各种形式的同步提供支持。

python提供了非常好用的多进程包multiprocessing,只需要定义一个函数,python会完成其他所有事情。借助这个包,可以轻松完成从单进程到并发执行的转换。multiprocessing支持子进程、通信和共享数据。语法格式如下:

process([group [, target [, name [, args [, kwargs]]]]])

进程间通信

多线程:共享变量很简单,直接定义全局 global 变量即可

多进程:全局变量在多个进程中不共享,进程之间的数据是独立的,默认情况下互不影响。

from multiprocessing import process
num=1
def work1():
    global num
    num+=5
    print('子进程1运行,num:',num)

def work2():
    global num
    num += 10
    print('子进程2运行,num:',num)


if __name__=='__main__':
    print('父进程开始运行')
    p1=process(target=work1)
    p2=process(target=work2)
    p1.start()
    p2.start()
    p1.join()
    p2.join()

 执行结果

父进程开始运行
子进程1运行,num:6
子进程2运行,num:11

  • 但是python也提供了这样的标准库。process进程的manager模块和pool进程的manager模块。 

 进程间共享数据

  • 共享数值型数据

主进程与子进程共用一个value

import multiprocessing


def func(num):
    num.value = 2  


if __name__ == "__main__":
    num = multiprocessing.value("d", 1) 
    p = multiprocessing.process(target=func, args=(num,))
    p.start()
    p.join()
  •  共享数组型数据

子进程改变dict,list,主进程dict,list跟着改变

共享list实践

现在想把每个手机的自动化运行结果的元组拿出来分析,使用共享list的方式

# 多进程中,同一个变量,各自有一份拷贝存在于每个进程中, 互不影响;
    # 多线程中,所有变量都由所有线程共享,任何一个变量都可以被任何一个线程修改.
    # multiprocessing.manager()实现多进程中的数据共享
    result_timeparam = multiprocessing.manager().list()
    result_report_name_list = multiprocessing.manager().list()
    result_tuple_list = multiprocessing.manager().list()
    devices_pool = []
    for tmp_udid in configdata().mobile_data().keys():
        devices_pool.append(multiprocessing.process(target=run_testcase, args=(tmp_udid,result_timeparam,result_report_name_list,
                                                                               result_tuple_list )))

    for devices_udid in devices_pool:
        devices_udid.start()

    for devices_udid in devices_pool:
        devices_udid.join()

得到的result_tuple_list:

[('2022-10-11 09:59:46', '共 1,通过 1,通过率= 100.00%', 'android', '7.1.2', 'samsung', '3.9.3.018'), ('2022-10-11 09:59:47', '共 1,通过 1,通过率= 100.00%', 'android', '10', 'oppo', '3.9.3.018')]

到此这篇关于python多进程实现数据共享的示例代码的文章就介绍到这了,更多相关python多进程数据共享内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!

(0)

相关文章:

版权声明:本文内容由互联网用户贡献,该文观点仅代表作者本人。本站仅提供信息存储服务,不拥有所有权,不承担相关法律责任。 如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 2386932994@qq.com 举报,一经查实将立刻删除。

发表评论

验证码:
Copyright © 2017-2025  代码网 保留所有权利. 粤ICP备2024248653号
站长QQ:2386932994 | 联系邮箱:2386932994@qq.com