2

我的代码如下所示：

... # class Site(Resource)
def render_POST(self,request)
   otherclass.doAssync(request.args)
   print '1'
   return "done" #that returns the HTTP response, always the same.

...

def doAssync(self,msg):
    d = defer.Deferred()
    reactor.callLater(0,self.doStuff,d,msg)
    d.addCallback(self.sucess)

def doStuff(self,d,msg):
    # do some stuff
    time.sleep(2)  #just for example
    d.callback('ok')

def sucess(msg):
    print msg

输出：

1

行

到目前为止，一切都很好，但是 HTTP 响应（返回“完成”）仅在延迟（time.sleep(2)）之后发生。我可以这么说，因为浏览器会保持“加载”2 秒。

我究竟做错了什么？

4

1 回答 1

4

您做错的是运行阻塞调用 ( time.sleep(2))，而 Twisted 期望您只执行非阻塞操作。等不及的事情。因为你有那个time.sleep(2)，Twisted 在该函数处于休眠状态时不能做任何其他事情。所以它也不能向浏览器发送任何数据。

在 的情况下time.sleep(2)，您可以将其替换为另一个reactor.callLater调用。假设您实际上意味着time.sleep(2)调用是其他一些阻塞操作，那么如何修复它取决于操作。如果您可以以非阻塞方式执行操作，请执行此操作。对于许多此类操作（如数据库交互），Twisted 已经提供了非阻塞替代方案。如果您正在做的事情没有非阻塞接口并且 Twisted 没有替代方案，您可能必须在单独的线程中运行代码（例如使用twisted.internet.threads.deferToThread），尽管这需要您的代码实际上是线程-安全的。

于 2012-02-16T12:31:52.067 回答