inlineCallbacks 函数内的回调

Question

假设我有一个像这样的函数：

def display(this, that):
    print this, that

和一个类：

class Runner(object):
    def __init__(self, callback):
        self.callback = callback
        self.loop = twisted.internet.task.LoopingCall(repeat)
        self.loop.start(0)

    @defer.inlineCallbacks
    def repeat(self):
        this = yield do_this()
        that = yield do_that()

        if this and that:
            # now I want to call the callback function
            yield self.callback(this, that) # makes sense?

runner = Runner(display)
reactor.run()

基本上我想做的是创建一个 Runner 类，它将执行一些特定的任务，并且每次获得结果时，它都会调用给定的回调函数。我不想创建一个执行特定操作的新函数，而是创建一个只执行一件事的通用类。例如：

class TwitterReader(object):
    def __init__(self, callback):
        ...
        ...

    @defer.inlineCallbacks
    def get_messages(self):
        ...
        ...
        yield callback(messages)

class MessageFilter(object):
    def __init__(self):
        self.bad_messages = open('bad_messages.txt', 'w')
        self.twitter = TwitterReader(self.message_received)

    def message_received(messages):
        for message in messages:
            for bad_word in BAD_WORDS:
                if bad_word in message:
                    self.bad_messages.write(message)
                    break

我是扭曲的新手。所以，我不确定这是否是正确的方法。是吗？

谢谢

Answer 1

您的问题是 repeat 中的 callback 应该改为 self.callback。

除此之外，您的示例应该完全按照编写的方式工作。

Answer 2

如果它返回延迟并且您希望在退出 repeat 函数之前等待结果，则您只需需要yield self.callback。在您的示例中，您的回调是一个普通函数（它实际上返回 None），因此生成没有任何优势 - 但是它允许生成非延迟值，因此不会造成任何损害。来自 inlineCallbacks 文档：

非 Deferreds 的东西也可能被产生，并且你的生成器
将恢复并发送回相同的对象。这意味着产量
执行大致相当于 MaybeDeferred 的操作。

如果您的回调did返回一个延迟函数（例如，如果它也是一个inlineCallbacks修饰函数），那么yielding将暂停repeat的执行，直到延迟函数完全的。这在您的应用程序中可能是理想的，也可能不是。