tornado_gracefull_stop

cmd.sh

parallel --no-notice curl localhost:8080/{} ::: 4 5 3 8 10

tornado_gracefull_stop.py

import tornado.ioloop
import tornado.web
import tornado.gen


class MyHandler(tornado.web.RequestHandler):
    @tornado.gen.coroutine
    def get(self, num):
        yield tornado.gen.sleep(int(num))
        self.write('res {}\n'.format(num))


def stop(loop, server):
    def soft_stop():
        if set(loop._handlers.keys()) - set([loop._waker.fileno()]):
            loop.call_later(1, soft_stop)
        else:
            loop.stop()
    print 'Stopping server, {}'.format(loop._handlers)
    server.stop()
    server.close_all_connections()
#class GracefulRequestHandler(tornado.web.RequestHandler):
#    def initialize(self):
#        if self.application.is_shutting_down:
#            self.set_header('Connection', 'close')
#            self.request.connection.no_keep_alive = True
    soft_stop()
    loop.call_later(30, loop.stop)

if __name__ == '__main__':
    loop = tornado.ioloop.IOLoop.current()
    app = tornado.web.Application([(r'/(.*)', MyHandler)])
    server = app.listen(8080, '127.0.0.1')
    loop.call_later(5, stop, loop, server)
    loop.start()