Skip to content

Instantly share code, notes, and snippets.

@kzahel

kzahel/nested_async_yield

Created September 27, 2012 21:53
Download ZIP

Revisions

  1. kzahel revised this gist Sep 27, 2012. 1 changed file with 4 additions and 2 deletions.
    6 changes: 4 additions & 2 deletions nested_async_yield
    View file
    Original file line number Diff line number Diff line change
    @@ -2,13 +2,15 @@ def asyncsleep(t, callback=None):
    ioloop.add_timeout( time.time() + t, callback )

    class NestedYieldAsync(tornado.web.RequestHandler):

    @tornado.web.asynchronous
    @gen.engine
    @tornado.gen.engine
    def get(self):
    yield gen.Task( self.lots_of_waits )
    yield gen.Task( self.lots_of_waits )
    self.finish()
    @gen.engine

    @tornado.gen.engine
    def lots_of_waits(self, callback=None):
    for i in range(3):
    print 'sleep',i
  2. kzahel revised this gist Sep 27, 2012. 1 changed file with 1 addition and 0 deletions.
    1 change: 1 addition & 0 deletions nested_async_yield
    View file
    Original file line number Diff line number Diff line change
    @@ -7,6 +7,7 @@ class NestedYieldAsync(tornado.web.RequestHandler):
    def get(self):
    yield gen.Task( self.lots_of_waits )
    yield gen.Task( self.lots_of_waits )
    self.finish()
    @gen.engine
    def lots_of_waits(self, callback=None):
    for i in range(3):
  3. kzahel created this gist Sep 27, 2012.
    15 changes: 15 additions & 0 deletions nested_async_yield
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,15 @@
    def asyncsleep(t, callback=None):
    ioloop.add_timeout( time.time() + t, callback )

    class NestedYieldAsync(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    @gen.engine
    def get(self):
    yield gen.Task( self.lots_of_waits )
    yield gen.Task( self.lots_of_waits )
    @gen.engine
    def lots_of_waits(self, callback=None):
    for i in range(3):
    print 'sleep',i
    yield gen.Task( asyncsleep, 1 )
    callback()