0

一个 PyPy 回调，当我将 Python 对象移动到单独的多处理进程中时（直接）实现（直接）作为 Python 对象的方法时，它完美地工作（在无限循环中），在大约 100 次迭代后出现段错误。

在我的主要代码中：

import multiprocessing as mp

class Task(object):

    def __init__(self, com, lib):

        self.com = com # communication queue
        self.lib = lib # ffi library
        self.proc = mp.Process(target=self.spawn, args=(self.com,))
        self.register_callback()

    def spawn(self, com):
        print('%s spawned.'%self.name)
        # loop (keeping 'self' alive) until BREAK:
        while True:
            cmd = com.get()
            if cmd == self.BREAK:
                break
        print("%s stopped."%self.name)

    @ffi.calback("int(void*, Data*"):   # old cffi (ABI mode)
    def callback(self, data):
        # <work on data>
        return 1

    def register_callback(self):
        s = ffi.new_handle(self)
        self.lib.register_callback(s, self.callback)  # C-call

这个想法是多个任务应该同时提供相同数量的回调。我不知道是什么导致了段错误，尤其是因为它在前 100 次左右的迭代中运行良好。非常感谢帮助！

4

1 回答 1

0

解决方案

从“register_callback()”返回时，句柄“s”被垃圾收集。使句柄成为“自我”的属性并传递使其保持活力。

标准 CPython (cffi 1.6.0) 在第一次迭代时出现了段错误（即 gc 是即时的），并为我提供了一条重要的信息错误消息。另一方面，PyPy 在大约 100 次迭代后出现了段错误，但没有提供消息……现在两者都运行良好。

于 2016-05-14T19:32:15.377 回答