C调用Cython多进程类遇Pickle序列化错误求助

1. 显式指定Cython类的__module__属性 #

在Cython类定义中强制指定__module__为模块全名，避免C导入时模块路径识别偏差导致类身份不匹配：

cdef class doThreadingStuff:
    __module__ = "cythonMod"  # 替换为你的实际模块名称
    # 类的其他属性与方法定义

重新编译生成pyd文件后，pickle会使用显式指定的模块名校验类身份，而非动态识别的可能不一致的路径。

2. 在C代码中缓存导入的模块对象 #

如果C代码中多次导入模块，会导致模块对象重复，进而引发类身份不匹配问题。修改C代码，确保模块仅被导入一次：

static PyObject* cython_mod = NULL;

// 初始化阶段一次性导入模块
if (!cython_mod) {
    cython_mod = PyImport_ImportModule("cythonMod");
    if (!cython_mod) {
        PyErr_Print();
        return -1;
    }
}

// 从缓存的模块中获取mainCode函数
PyObject* main_code = PyObject_GetAttrString(cython_mod, "mainCode");
if (!main_code || !PyCallable_Check(main_code)) {
    PyErr_Print();
    Py_XDECREF(main_code);
    return -1;
}

// 调用mainCode函数
PyObject* result = PyObject_CallObject(main_code, NULL);
// 后续资源清理逻辑

3. 为Cython类自定义Pickle序列化逻辑 #

实现__reduce__方法绕过默认的类身份检查，直接定义序列化规则：

cdef class doThreadingStuff:
    __module__ = "cythonMod"
    
    cdef object pipe
    cdef object task_queue
    
    def __reduce__(self):
        # 返回类构造器及可序列化的初始化参数
        return (self.__class__, (self.pipe, self.task_queue))
    
    def __init__(self, pipe, task_queue):
        self.pipe = pipe
        self.task_queue = task_queue
        # 类的其他初始化逻辑

这样pickle会直接使用你定义的逻辑序列化对象，不再依赖类的身份匹配。

4. 转由Python侧调度Cython类实例 #

既然需要和PyQt5共享Pipe、Queue，可在Python侧封装Cython类的实例管理，C代码仅调用Python侧的调度接口：
创建Python封装脚本cython_wrapper.py：

from cythonMod import doThreadingStuff
import multiprocessing as mp
import queue

# 初始化共享资源与Cython类实例
shared_pipe = mp.Pipe()
shared_queue = queue.Queue()
threading_inst = doThreadingStuff(shared_pipe[0], shared_queue)

def get_shared_resources():
    return shared_pipe[1], shared_queue

C代码导入该脚本，调用get_shared_resources获取共享对象，由Python侧管理doThreadingStuff实例，避免C导入模块导致的类身份问题。

内容的提问来源于stack exchange，提问作者sdfdf