如何在 Python 多进程 Pool 中安全共享全局计数器

秋丽君_4448

秋丽君_4448

2026-06-30

970人浏览

原创

如何在 Python 多进程 Pool 中安全共享全局计数器

本文详解如何在 multiprocessing.pool 中正确使用 multiprocessing.value 实现跨进程共享计数器,避免“synchronized objects should only be shared through inheritance”错误,并提供可直接运行的完整示例。

本文详解如何在 multiprocessing.pool 中正确使用 multiprocessing.value 实现跨进程共享计数器,避免“synchronized objects should only be shared through inheritance”错误,并提供可直接运行的完整示例。

在 Python 多进程编程中,直接将 multiprocessing.Value 实例作为实例属性(如 self.counter)传入 Pool 的工作函数会导致序列化失败——因为 Value 对象只能通过进程继承(inheritance)方式共享,而不能通过 pickle 序列化后传递给子进程。原始代码中 self.counter 在 __init__ 中创建,随后随 self._process_data 方法被 starmap 间接传递,触发了 RuntimeError。

正确的做法是将 Value 声明为类变量(class variable),使其在模块级定义、由父进程创建,并自然继承至所有子进程。子进程通过类名(如 DemoProcessor.counter)访问该共享内存对象,无需序列化,从而规避错误。

此外需注意:

Python数据分析(免费版)
Python数据分析(免费版)

提供Python数据清洗、统计分析与可视化建议,覆盖业务报表与科研数据的快速处理流程。

下载
  • starmap 要求传入的是可迭代的元组序列(如 [(arg1,), (arg2,), ...]),而非简单列表 list(range(10));否则会因参数解包失败导致运行时异常。
  • 计数器操作(counter.value += 1)虽为原子读写,但在高并发下仍建议用 Lock 保障严格顺序(本例为演示简化,未加锁;生产环境推荐封装为线程/进程安全的 increment 方法)。

以下是修正后的完整可运行代码:

import multiprocessing
from ctypes import c_int
from multiprocessing import Value
from random import random
from time import sleep


class DemoProcessor(object):
    # ✅ 正确:声明为类变量,由主进程创建,子进程自动继承
    counter = Value(c_int, 0)

    def __init__(self, data_to_process):
        # ✅ 数据需为元组列表,适配 starmap 参数解包
        self.data_to_process = [(item,) for item in data_to_process]

    def _process_data(self, item):
        print(f"Processing {item=}")
        sleep(random() * 0.5)  # 模拟耗时操作,凸显并发效果
        # ✅ 通过类名访问共享计数器
        DemoProcessor.counter.value += 1
        print(f"Processed {item=}, total completed: {DemoProcessor.counter.value}")

    def process(self):
        with multiprocessing.Pool(processes=4) as pool:
            # ✅ 使用上下文管理器确保资源正确释放
            pool.starmap(self._process_data, self.data_to_process)


if __name__ == "__main__":
    demo = DemoProcessor(data_to_process=list(range(10)))
    demo.process()
    print(f"\n✅ Final count: {DemoProcessor.counter.value}")

关键要点总结:

  • 共享状态对象(Value, Array, Lock 等)必须定义在模块或类顶层,不可封装在实例中传递
  • Pool 子进程通过 fork 继承父进程内存空间,因此类变量中的 Value 自动可用;
  • 始终验证输入数据格式(starmap → 元组列表,map → 单参数列表);
  • 若需精确计数顺序或避免竞争,可配合 Lock 使用:
    with DemoProcessor.counter.get_lock():
        DemoProcessor.counter.value += 1

此方案简洁、可靠,是 Python 多进程共享状态的推荐实践。

Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

python

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

2023.07.20

1531

4

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

2023.07.25

3564

7

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.07.31

1549

3

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

2023.08.03

20257

23

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

2527

5

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

2587

5

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

1063

5

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.10

576

4

python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2003

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程