__main__.py 文件源码

def get(self, udid):
        ''' get new task '''
        timeout = self.get_argument('timeout', 20.0)
        if timeout is not None:
            timeout = float(timeout)
        que = self.ques[udid]
        try:
            item = yield que.get(timeout=time.time()+timeout) # timeout is a timestamp, strange
            print 'get from queue:', item
            self.write(item)
            que.task_done()
        except gen.TimeoutError:
            print 'timeout'
            self.write('')
        finally:
            self.finish()