Python multiprocessing 共享对象的示例代码

 更新时间:2023年07月07日 09:08:10   作者:迹忆客  
在 Python 中使用 multiprocessing,一个新的进程可以独立运行并拥有自己的内存空间,下面通过示例代码讲解Python multiprocessing共享对象的相关知识,感兴趣的朋友跟随小编一起看看吧

在 Python 中,共享内存多处理由连接多个处理器组成,但这些处理器必须能够直接访问系统的主内存。 这将允许所有连接的处理器访问它们使用或创建的其他处理器数据。

在多进程中使用 Python 共享内存对象

在 Python 中使用 multiprocessing,一个新的进程可以独立运行并拥有自己的内存空间。 通过查看下面的示例,让我们详细了解使用 Python 的共享对象多处理。

示例代码:

import multiprocessing
#an empty array globally declared
answer = []
def square_numbers(mynumbers):
#for squaring array elements, a function has been used
    global answer
    #appending square numbers to a global array
    for n in mynumbers:
        answer.append(n * n)
    #print a global array for generating an answer
    print("Answer using first process: {}".format(answer))
if __name__ == "__main__":
    #input array
    mynumbers = [5,10,15]
    #new process has been created
    p = multiprocessing.Process(target=square_numbers, args=(mynumbers,))
    #process begins here
    p.start()
    #wait unless a process is completed
    p.join()
    #print a global array for generating an answer
    print("Answer using main program: {}".format(answer))

输出:

Answer using first process: [25, 100, 225]
Answer using main program: []

我们使用上面的例子在两个地方打印了全局数组答案。

进程 p 调用 square_numbers 函数,以便在内存空间中为进程 p 更改数组元素。

主程序在进程 p 完成后运行,我们将在内存空间中得到一个空数组作为答案。

Python 中的多处理提供了值对象和一个数组,用于在多个进程之间共享数据。

示例代码:

import multiprocessing
def square_data(mydata, answer, square_sum):
  #a function has been made for squaring of given data
    #appending squares of mydata to the given array
    for ix, n in enumerate(mydata):
        answer[ix] = n * n
    #sum the square values
    square_sum.value = sum(answer)
    #print array of squared values for process p
    print("Answer in process p: {}".format(answer[:]))
    # print the sum of squared values for process p
    print("Sum of squares values in process p: {}".format(square_sum.value))
if __name__ == "__main__":
    #here, we input the data
    mydata = [1,2,3]
    #an array has been created for the int data type for three integers
    answer = multiprocessing.Array('i', 3)
    #value has been created for int data type
    square_sum = multiprocessing.Value('i')
    #new process has been created
    p = multiprocessing.Process(target=square_data, args=(mydata, answer, square_sum))
    #process begins from here
    p.start()
    #wait unless the process is completed
    p.join()
    # print an array of squared values for the main program
    print("Answer in main program: {}".format(answer[:]))
    # print the sum of squared values for the main program
    print("Sum of square values in main program: {}".format(square_sum.value))

输出:

Answer in process p: [1, 4, 9]
Sum of squares in process p: 14
Answer in main program: [1, 4, 9]
Sum of squares in main program: 14

在上面的示例中,我们创建了一个数组并将三个整数传递给它。 我们打印了一个平方值数组,然后是进程 p 的平方值之和。

在此之后,我们再次为主程序打印一个平方值数组和平方值之和。

总结

可以通过多种方式来解释使用 Python 的共享内存多处理。 因此,在本文中,我们解释了多进程共享内存概念,即一个对象如何放置在共享内存空间并独立运行。

除此之外,我们还了解到 Python 允许进程在不同进程之间共享数据。

到此这篇关于Python multiprocessing 共享对象的文章就介绍到这了,更多相关Python multiprocessing 共享内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 使用Python的Turtle库绘制森林的实例

    使用Python的Turtle库绘制森林的实例

    今天小编就为大家分享一篇使用Python的Turtle库绘制森林的实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-12-12
  • python打开网页和暂停实例

    python打开网页和暂停实例

    这篇文章主要介绍了python打开网页和暂停实例,涉及webbrowser模块与os模块的使用,是非常具有实用价值的一个技巧,需要的朋友可以参考下
    2014-09-09
  • python解决字符串倒序输出的问题

    python解决字符串倒序输出的问题

    今天小编就为大家分享一篇python解决字符串倒序输出的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-06-06
  • Python入门篇之字符串

    Python入门篇之字符串

    可能大多数人在学习C语言的时候,最先接触的数据类型就是字符串,因为大多教程都是以"Hello world"这个程序作为入门程序,这个程序中要打印的"Hello world"就是字符串。今天我们来了解一下Python中的字符串,看看它的用法。
    2014-10-10
  • Python PIL库Image函数的基本图像处理操作实例

    Python PIL库Image函数的基本图像处理操作实例

    这篇文章主要为大家介绍了Python PIL库Image函数的基本图像处理操作实例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2024-01-01
  • Java 超详细讲解核心类Spring JdbcTemplate

    Java 超详细讲解核心类Spring JdbcTemplate

    JdbcTemplate JdbcTemplate是Spring JDBC核心包(core)中的核心类,它可以通过配置文件、注解、Java 配置类等形式获取数据库的相关信息,实现了对JDBC开发过程中的驱动加载、连接的开启和关闭、SQL语句的创建与执行、异常处理、事务处理、数据类型转换等操作的封装
    2022-04-04
  • 如何使用Django(python)实现android的服务器端

    如何使用Django(python)实现android的服务器端

    这篇文章主要介绍了Django(python)简单实现android的服务器端,这里所需要的工具是PyCharm--python编辑工具,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-07-07
  • Jupyter Notebook内使用argparse报错的解决方案

    Jupyter Notebook内使用argparse报错的解决方案

    这篇文章主要介绍了在Jupyter Notebook内使用argparse报错的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • 使用pyecharts无法import Bar的解决方案

    使用pyecharts无法import Bar的解决方案

    这篇文章主要介绍了使用pyecharts无法import Bar的解决方案,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2017-01-01
  • Python绘制简单散点图的方法

    Python绘制简单散点图的方法

    这篇文章主要为大家详细介绍了Python绘制简单散点图的方法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-04-04

最新评论