2

(tornado を使用して) 大きなデータを低速のクライアントに転送し、転送されたデータの量を出力するとします。この目的のために、次の簡単なコードを書きました。

from tornado import web, ioloop, gen

class MainHandler(web.RequestHandler):
    @web.asynchronous
    @gen.engine
    def get(self):
        print '( start'
        try:
            for i in xrange(100):
                self.write('*' * 100000)  # write ~100KB of data
                yield gen.Task(self.flush)  # wait for reciever to recieve
                print '- wrote', i
        finally:
            print '| finally'
            self.finish()
        print ') finish'

application = web.Application([
    (r"/", MainHandler),
    ])

application.listen(8888)
ioloop.IOLoop.instance().start()

しかし、このコードは期待どおりに動作しません。たとえば、次の単純なクライアントでは:

req = urlopen('http://127.0.0.1:8888/')
sys.exit()  # exit without reading response

サーバーはこれを出力します：

( start
- wrote 0
- wrote 1
- wrote 2
WARNING:root:Read error on 7: [Errno 104] Connection reset by peer
WARNING:root:error on read
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/tornado-2.4.1-py2.7.egg/tornado/iostream.py", line 361, in _handle_read
    if self._read_to_buffer() == 0:
  File "/usr/local/lib/python2.7/dist-packages/tornado-2.4.1-py2.7.egg/tornado/iostream.py", line 428, in _read_to_buffer
    chunk = self._read_from_socket()
  File "/usr/local/lib/python2.7/dist-packages/tornado-2.4.1-py2.7.egg/tornado/iostream.py", line 409, in _read_from_socket
    chunk = self.socket.recv(self.read_chunk_size)
error: [Errno 104] Connection reset by peer

しかし、どちらfinallyもfinish印刷されません。

どうしたの？！

アップデート：

on_connection_closeハンドラーに実装すると、on_connection_closeコールバックが呼び出され、コンソールにエラーが出力されないことに気付きました。しかし、この機能は何の魔法でしょうか? RequestHandler（私はすでに空のボディで定義しています）。

そしてより大きな答え: なぜ私のジェネレーターはclosed ではないのですか? ガベージコレクションかどうか？PEP-342 は、どのような状況でも finally ブロックを実行する必要があると述べています。

4

1 に答える 1

1

finally句を含むジェネレータは__del__、Python バージョン <= 3.3 を使用して実装され、他のデストラクタのすべての制限があります。参照サイクルが存在する場合でも、すぐに実行される保証はありません。Python 3.4 ではこれが改善され ( http://www.python.org/dev/peps/pep-0442/ )、ジェネレーターの finally 句がより確実に実行されるようになりました。

于 2013-09-26T04:34:32.503 に答える