Python Twisted Deferred：需要澄清

Question

我想请教一下，处理“第一个”延迟对象的最佳方法是什么。也就是说，不仅仅是给现有的返回延迟对象的Twisted方法添加回调和错误回调，而是如何创建这些原始的延迟对象。

举个具体的例子，这里有两个相同方法的变体：它只是计算一些比较大的文本文件中的行数，并作为一系列延迟对象的起点。

方法 1： 这个方法感觉不太好，因为延迟对象是直接通过reactor.callLater方法触发的。

def get_line_count(self):
    deferred = defer.Deferred()

    def count_lines(result):
        try:
            print_file = file(self.print_file_path, "r")
            self.line_count = sum(1 for line in print_file)
            print_file.close()
            return self.line_count
        except Exception as inst:
            raise InvalidFile()

     deferred.addCallback(count_lines)
     reactor.callLater(1, deferred.callback, None)
     return deferred

方法 2： 这个稍微好一点，因为延迟对象实际上是在结果可用时触发的。

def get_line_count(self):
    deferred = defer.Deferred()

    def count_lines():
        try:
            print_file = file(self.print_file_path, "r")
            self.line_count = sum(1 for line in print_file)
            print_file.close()
            deferred.callback(self.line_count)
        except Exception as inst:
            deferred.errback(InvalidFile())

    reactor.callLater(1, count_lines)
    return deferred

注意：你也可以指出这两种方法实际上都是同步的，可能会阻塞的方法，（我可能可以使用“MaybeDeferred”？）。不过，这确实是让我感到困惑的一个方面。

对于方法 2，如果count_lines方法非常慢（比如计算一些超大文件的行数等），这会不会“阻塞”整个Twisted应用？我读了很多关于回调、错误回调和反应器如何一起工作的文档（回调需要快速执行，或者自己返回延迟对象等），但在这种情况下，我就是看不明白，真的很希望能得到一些指点/示例等。
有没有一些文章/清晰的解释，讲述创建这些“第一个”延迟对象的最佳方法？我读过这些优秀的文章，它们在一些基本理解上帮助很大，但我仍然觉得缺少了一些东西。
对于阻塞代码，这是否是使用DeferToThread或reactor.spawnprocess的典型案例？我读过很多类似于这个问题和这篇文章，但我仍然不太确定如何处理可能会阻塞的代码，尤其是在处理文件输入输出时。

抱歉如果这些内容看起来太基础，但我真的想更深入地掌握使用Twisted的技巧。（它在网络相关的方面是一个非常强大的工具）。谢谢你的时间！

异步编程 twisted reactor 非阻塞编程文件输入输出延迟对象回调 deferToThread

Python Twisted Deferred：需要澄清

1 个回答

撰写回答