multiprocessing 模块的 Manager

2024-06-28 1116阅读

 multiprocessing 模块的 Manager 类提供了一个机制,允许多个进程共享数据结构。 Manager 对象可以创建多种可被多个进程共享的数据结构,如列表、字典、集合等。以下是 Manager 的一些常用属性和方法:

multiprocessing 模块的 Manager
(图片来源网络,侵删)

属性:

 address : 包含绑定到的地址和端口的元组,如果使用默认服务器,则为 ('localhost', 随机端口号) 。

方法:

 list() : 创建一个可以被多个进程共享的列表。

 dict() : 创建一个可以被多个进程共享的字典。

 Queue() : 创建一个可以被多个进程共享的队列。

 Value : 创建一个可以被多个进程共享的值。这个值可以是 multiprocessing 模块中的基本数据类型,如 multiprocessing.Value 。

 Array : 创建一个可以被多个进程共享的数组。这个数组可以是 multiprocessing 模块中的 multiprocessing.Array 。

 Namespace() : 创建一个可以被多个进程共享的命名空间。

 Barrier(parties[, action]) : 创建一个同步屏障,所有进程必须到达屏障点才能继续执行。

 Condition([lock]) : 创建一个可以被多个进程共享的条件变量。

 Event() : 创建一个可以被多个进程共享的事件。

 Lock() : 创建一个可以被多个进程共享的锁。

 RLock() : 创建一个可以被多个进程共享的可重入锁。

 Semaphore(value) : 创建一个可以被多个进程共享的信号量。

 BoundedSemaphore(value) : 创建一个可以被多个进程共享的有界信号量。

 start() : 启动管理器进程,如果管理器进程已经启动,则此方法无效。

 shutdown() : 关闭管理器进程,释放资源。

例子:

python

复制

from multiprocessing import Manager

# 创建一个Manager对象

manager = Manager()

# 使用Manager创建共享数据结构

shared_list = manager.list()

shared_dict = manager.dict()

shared_queue = manager.Queue()

# 其他操作...

请注意, Manager 对象创建的共享数据结构在默认情况下是使用 multiprocessing 模块的服务器进程来管理的。这意味着,如果所有的进程都结束了,管理器进程也会退出,导致共享数据结构无法访问。使用 Manager 时,应该在所有进程都完成之后调用 shutdown() 方法来正确关闭管理器进程。

由于Python的版本更新, multiprocessing 模块的API也可能发生变化,所以建议查看最新的官方文档以获取最准确的信息。

 

 

VPS购买请点击我

免责声明:我们致力于保护作者版权,注重分享,被刊用文章因无法核实真实出处,未能及时与作者取得联系,或有版权异议的,请联系管理员,我们会立即处理! 部分文章是来自自研大数据AI进行生成,内容摘自(百度百科,百度知道,头条百科,中国民法典,刑法,牛津词典,新华词典,汉语词典,国家院校,科普平台)等数据,内容仅供学习参考,不准确地方联系删除处理! 图片声明:本站部分配图来自人工智能系统AI生成,觅知网授权图片,PxHere摄影无版权图库和百度,360,搜狗等多加搜索引擎自动关键词搜索配图,如有侵权的图片,请第一时间联系我们,邮箱:ciyunidc@ciyunshuju.com。本站只作为美观性配图使用,无任何非法侵犯第三方意图,一切解释权归图片著作权方,本站不承担任何责任。如有恶意碰瓷者,必当奉陪到底严惩不贷!

目录[+]