Python3中GdkPixbuf.Pixbuf对象Pickle与进程间传递问题

我懂你遇到的麻烦了——当你尝试用pickle序列化GdkPixbuf.Pixbuf对象（包括通过multiprocessing.Queue在进程间传递时的自动序列化），反序列化后的对象直接变成了未初始化的空壳。这是因为PyGObject封装的C原生对象，默认的pickle逻辑只保存了Python层面的包装器信息，压根没把底层的像素数据一起序列化进去。

原因拆解 #

GdkPixbuf.Pixbuf是对GTK底层C语言GdkPixbuf结构体的Python包装，默认的pickle操作只会记录Python对象的引用信息，不会处理C内存里存的实际像素数据。所以反序列化时，你得到的只是一个空的Python包装壳，底层的GdkPixbuf指针是nil（空）的，自然没法正常使用。

可行解决方案 #

核心思路就是把Pixbuf的实际数据转换成可序列化的格式，传递完成后再还原回来，这里有两种靠谱的实现方式：

方案一：手动转成字节流（推荐，兼容性好） #

把Pixbuf编码成PNG/JPG这类标准图片格式的字节数据，传递后再从字节数据重建Pixbuf。这种方式不需要修改类的默认行为，上手简单：

import gi
gi.require_version('GdkPixbuf', '2.0')
from gi.repository import GdkPixbuf
import pickle
import multiprocessing

def pixbuf_to_bytes(pixbuf):
    """将Pixbuf转为PNG格式的字节数据"""
    buffer = pixbuf.save_to_buffer("png", {"quality": "100"})
    return buffer

def bytes_to_pixbuf(data):
    """从字节数据重建Pixbuf"""
    loader = GdkPixbuf.PixbufLoader.new_with_type("png")
    loader.write(data)
    loader.close()
    return loader.get_pixbuf()

# 测试序列化/反序列化流程
pf = GdkPixbuf.Pixbuf.new_from_file('_icon.png')
print("原Pixbuf对象:", pf)

# 转成字节后进行pickle
pixbuf_bytes = pixbuf_to_bytes(pf)
pickle.dump(pixbuf_bytes, open('p', 'wb'))

# 反序列化后重建Pixbuf
loaded_bytes = pickle.load(open('p', 'rb'))
pb2 = bytes_to_pixbuf(loaded_bytes)
print("重建后的Pixbuf对象:", pb2)

# 进程间传递的实际示例
def worker(queue):
    # 子进程加载图片并转成字节发送
    pf = GdkPixbuf.Pixbuf.new_from_file('_icon.png')
    queue.put(pixbuf_to_bytes(pf))

if __name__ == '__main__':
    queue = multiprocessing.Queue()
    process = multiprocessing.Process(target=worker, args=(queue,))
    process.start()
    process.join()
    
    # 主进程接收并重建Pixbuf
    received_bytes = queue.get()
    received_pixbuf = bytes_to_pixbuf(received_bytes)
    print("主进程收到的Pixbuf对象:", received_pixbuf)

方案二：注册自定义pickle逻辑 #

如果你不想每次手动转换，可以通过copyreg模块为GdkPixbuf.Pixbuf类注册自定义的序列化/反序列化函数，这样直接pickle对象时就会自动处理数据：

import gi
gi.require_version('GdkPixbuf', '2.0')
from gi.repository import GdkPixbuf
import pickle
import copyreg
import multiprocessing

def _pickle_pixbuf(pixbuf):
    """自定义序列化函数：返回重建函数和所需参数"""
    buffer = pixbuf.save_to_buffer("png", {"quality": "100"})
    return (_unpickle_pixbuf, (buffer,))

def _unpickle_pixbuf(data):
    """自定义反序列化函数：从字节数据重建Pixbuf"""
    loader = GdkPixbuf.PixbufLoader.new_with_type("png")
    loader.write(data)
    loader.close()
    return loader.get_pixbuf()

# 为Pixbuf类注册自定义pickle逻辑
copyreg.pickle(GdkPixbuf.Pixbuf, _pickle_pixbuf, _unpickle_pixbuf)

# 现在可以直接pickle/unpickle对象了
pf = GdkPixbuf.Pixbuf.new_from_file('_icon.png')
print("原Pixbuf对象:", pf)

pickle.dump(pf, open('p', 'wb'))
pb2 = pickle.load(open('p', 'rb'))
print("反序列化后的Pixbuf对象:", pb2)

# multiprocessing.Queue也能直接传递Pixbuf对象了
def worker(queue):
    pf = GdkPixbuf.Pixbuf.new_from_file('_icon.png')
    queue.put(pf)

if __name__ == '__main__':
    queue = multiprocessing.Queue()
    process = multiprocessing.Process(target=worker, args=(queue,))
    process.start()
    process.join()
    
    received_pixbuf = queue.get()
    print("主进程收到的Pixbuf对象:", received_pixbuf)

额外注意点 #

• 如果你对传输体积有要求，可以换成JPG格式并调整quality参数，或者用WebP这类更高效的格式（前提是你的GdkPixbuf支持对应的加载器）。
• 子进程里一定要正确初始化GdkPixbuf（先调用gi.require_version再导入），否则重建Pixbuf时会报错。

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