扭曲：“defer.execute”和“threads.deferToThread”之间的区别

Question

在twisted中，defer.execute()和threads.deferToThread()有什么区别？两者都采用相同的参数 - 一个函数和调用它的参数 - 并返回一个 deferred ，它将随着调用函数的结果而被触发。

threads 版本明确指出它将在线程中运行。但是，如果 defer 版本没有，那么调用它还有什么意义呢？在反应器中运行的代码永远不应该阻塞，因此它调用的任何函数都必须不阻塞。此时，您可以使用 defer.succeed(f(*args, **kwargs)) 而不是 defer.execute(f, args, kwargs) 来执行相同的结果。

Answer 1

defer.execute 确实在同一线程中以阻塞方式执行该函数，并且您是正确的，因为 defer.execute(f, args, kwargs) 与 defer.succeed 的作用相同(f(*args, **kwargs)) 除了，如果函数 f，defer.execute 将返回一个已触发 errback 的回调 抛出异常。同时，在您的 defer.succeed 示例中，如果函数抛出异常，它将向外传播，这可能是不希望的。

为了便于理解，我将 defer.execute 的源代码粘贴在这里：

def execute(callable, *args, **kw):
    """Create a deferred from a callable and arguments.

    Call the given function with the given arguments.  Return a deferred which
    has been fired with its callback as the result of that invocation or its
    errback with a Failure for the exception thrown.
    """
    try:
        result = callable(*args, **kw)
    except:
        return fail()
    else:
        return succeed(result)

换句话说，defer.execute 只是将阻塞函数的结果作为延迟的快捷方式，然后您可以添加它回调/错误返回。回调将使用正常的链接语义来触发。这看起来有点疯狂，但 Deferreds 可以在添加回调之前“触发”，并且回调仍然会被调用。

---

因此，回答您的问题，为什么这有用？好吧，defer.execute 对于测试/模拟以及简单地将异步 api 与同步代码集成都很有用。

同样有用的是 defer.maybeDeferred ，它调用函数，然后如果函数已经返回 deferred 则简单地返回它，否则函数类似于 defer.execute 。当您编写一个需要可调用的 API 并在调用时为您提供延迟，并且您也希望能够接受正常的阻塞函数时，这非常有用。

例如，假设您有一个应用程序可以获取页面并使用它执行操作。而且，出于某种原因，您需要针对特定​​用例以同步方式运行它，例如在单次 crontab 脚本中，或响应 WSGI 应用程序中的请求，但仍保留相同的代码库。如果您的代码如下所示，则可以这样做：

from twisted.internet import defer
from twisted.web.client import getPage

def process_feed(url, getter=getPage):
    d = defer.maybeDeferred(getter, url)
    d.addCallback(_process_feed)

def _process_feed(result):
    pass # do something with result here

要在没有反应器的同步上下文中运行此代码，您只需传递一个备用​​ getter 函数，如下所示：

from urllib2 import urlopen

def synchronous_getter(url):
    resp = urlopen(url)
    result = resp.read()
    resp.close()
    return result