我试图将缓慢的计算放入线程内,并收到错误“Request.write 在调用 Request.finish 后对请求进行了调用。”
我已经查看了答案,发现完全相同的问题,但解决方案对我不起作用。请指教。
from twisted.web.server import Site, NOT_DONE_YET
from twisted.web.resource import Resource
from twisted.internet import reactor, threads
from twisted.python import log
import sys
import time
def SlowComputation():
time.sleep(10)
return "Lang Computation Result"
def FastComputation():
return "Fast Computation Result"
class PerformComputation(Resource):
def Success(self, request):
request.write('Success')
request.finish()
def Failure(self, request):
request.write('Failure')
request.finish()
def render_GET(self, request):
if 'fast' in request.args:
d = threads.deferToThread(FastComputation)
d.addCallback(self.Success(request))
return NOT_DONE_YET
if 'slow' in request.args:
d = threads.deferToThread(SlowComputation)
d.addCallback(self.Success(request))
return NOT_DONE_YET
log.startLogging(sys.stdout)
root = Resource()
root.putChild("calculate", PerformComputation())
factory = Site(root)
reactor.listenTCP(8880, factory, interface='localhost')
reactor.run()
最佳答案
这个:
d.addCallback(self.Success(request))
等同于:
temp = self.Success(request)
d.addCallback(temp)
鉴于Success
的定义与:
request.write('Success')
request.finish()
temp = None
d.addCallback(None)
这可能会失败,在调用 Request.finish 后对请求调用 Request.write。因为 d.addCallback(None)
引发异常并且服务器尝试报告错误作为响应。但是,由于 finish
已被调用,因此无法写入错误。
使用额外参数向 Deferred
添加回调的正确方法是 d.addCallback(self.Success, request)
。不过,Deferred
上的回调总是将 Deferred
的结果作为第一个参数传递 - 因此 Success< 的正确签名
是:
def Success(self, result, request):
...
关于python - 调用 Request.finish 后在请求上调用 Twisted 错误 : Request. write,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19272307/