使用 C++ 扩展 Python 时理解和避免内存泄漏-Python教程-PHP中文网

使用 C++ 扩展 Python 时理解和避免内存泄漏

碧海醫心

发布： 2025-07-12 18:22:29

原创

347人浏览过

使用 c++ 扩展 python 时理解和避免内存泄漏

本文旨在帮助开发者理解在使用 C++ 扩展 Python 时可能出现的内存泄漏问题，并提供相应的解决方案。我们将通过一个具体的示例，分析内存泄漏的原因，并给出正确的引用计数管理方法，确保 Python 解释器的内存得到有效释放。

内存泄漏的根源：引用计数

Python 使用引用计数机制来管理内存。每个 Python 对象都有一个引用计数，当引用计数变为 0 时，对象就会被垃圾回收器回收。在使用 C++ 扩展 Python 时，我们需要手动管理 Python 对象的引用计数，以避免内存泄漏。

如果 C++ 代码创建了一个 Python 对象，并将其返回给 Python 解释器，那么 C++ 代码需要确保该对象的引用计数是正确的。如果引用计数过高，Python 解释器将永远不会回收该对象，从而导致内存泄漏。

示例分析：radec_to_xyz 函数

考虑以下 C++ 函数，该函数用于将赤经 (RA) 和赤纬 (Dec) 坐标转换为笛卡尔坐标 (X, Y, Z)：

立即学习“Python免费学习笔记（深入）”；

extern "C" PyObject *radec_to_xyz(PyObject *self, PyObject *args) {
    // 解析输入参数
    PyArrayObject *ra_arrobj, *dec_arrobj;
    if (!PyArg_ParseTuple(args, "O!O!", &PyArray_Type, &ra_arrobj, &PyArray_Type, &dec_arrobj)) {
        PyErr_SetString(PyExc_TypeError, "invalid arguments, expected two numpy arrays");
        return nullptr;
    }
    // 省略了输入检查，确保：
    // dtype==float64, dim==1, len()>0 且输入数据长度相等、连续
    npy_intp size = PyArray_SIZE(ra_arrobj);

    // 创建输出 numpy 数组，大小和数据类型与输入相同
    PyObject *x_obj = PyArray_EMPTY(1, &size, NPY_FLOAT64, 0);
    if (!x_obj) return nullptr;
    Py_XINCREF(x_obj);

    // 获取数组指针
    double *ra_array = static_cast<double *>(PyArray_DATA(ra_arrobj));
    double *dec_array = static_cast<double *>(PyArray_DATA(dec_arrobj));
    double *x_array = static_cast<double *>(PyArray_DATA(reinterpret_cast<PyArrayObject*>(x_obj)));

    // 计算新的坐标
    for (npy_intp i = 0; i < size; ++i) {
        double cos_ra = cos(ra_array[i]);
        double cos_dec = cos(dec_array[i]);
        // 计算最终坐标
        x_array[i] = cos_ra * cos_dec;
    }
    // 返回包含新坐标的数组
    return Py_BuildValue("O", x_obj);
}

登录后复制

这段代码存在内存泄漏。问题在于 Py_XINCREF(x_obj) 的使用。Py_BuildValue("O", x_obj) 会自动增加 x_obj 的引用计数。因此，手动增加引用计数会导致引用计数增加两次，从而阻止 Python 解释器回收 x_obj 对象。

解决方案：移除多余的引用计数增加

要解决这个问题，只需删除 Py_XINCREF(x_obj) 行即可。修改后的代码如下：

extern "C" PyObject *radec_to_xyz(PyObject *self, PyObject *args) {
    // 解析输入参数
    PyArrayObject *ra_arrobj, *dec_arrobj;
    if (!PyArg_ParseTuple(args, "O!O!", &PyArray_Type, &ra_arrobj, &PyArray_Type, &dec_arrobj)) {
        PyErr_SetString(PyExc_TypeError, "invalid arguments, expected two numpy arrays");
        return nullptr;
    }
    // 省略了输入检查，确保：
    // dtype==float64, dim==1, len()>0 且输入数据长度相等、连续
    npy_intp size = PyArray_SIZE(ra_arrobj);

    // 创建输出 numpy 数组，大小和数据类型与输入相同
    PyObject *x_obj = PyArray_EMPTY(1, &size, NPY_FLOAT64, 0);
    if (!x_obj) return nullptr;
    //Py_XINCREF(x_obj);  // 删除此行

    // 获取数组指针
    double *ra_array = static_cast<double *>(PyArray_DATA(ra_arrobj));
    double *dec_array = static_cast<double *>(PyArray_DATA(dec_arrobj));
    double *x_array = static_cast<double *>(PyArray_DATA(reinterpret_cast<PyArrayObject*>(x_obj)));

    // 计算新的坐标
    for (npy_intp i = 0; i < size; ++i) {
        double cos_ra = cos(ra_array[i]);
        double cos_dec = cos(dec_array[i]);
        // 计算最终坐标
        x_array[i] = cos_ra * cos_dec;
    }
    // 返回包含新坐标的数组
    return Py_BuildValue("O", x_obj);
}

登录后复制

通过删除多余的 Py_XINCREF(x_obj)，我们确保 x_obj 的引用计数在返回给 Python 解释器时是正确的，从而避免了内存泄漏。