handle periodic jobs on tornado's ioloop

gistfile1.py

#!/usr/bin/env python

import os
import sys
import time
import tornado.ioloop

class PeriodicServer(object):
  def __init__(self, request_callback, io_loop=None, period=1):
    self.request_callback = request_callback
    self.io_loop = tornado.ioloop.IOLoop.instance() if io_loop is None else io_loop
    self.timeouts = []
    self.period = period

  def _tick(self):
    try:
      self.request_callback()
    finally:
      self.io_loop.add_timeout(time.time() + self.period, self._tick)

  def start(self):
    timeouts = self.timeouts
    self.timeouts = []
    for timeout in timeouts:
      self.io_loop.remove_timeout(timeout)
    self.timeouts.append(self.io_loop.add_timeout(time.time(), self._tick))

  def stop(self):
    for timeout in self.timeouts:
      self.io_loop.remove_timeout(timeout)

def run():
  print "hello"

server = PeriodicServer(run)
server.start()

tornado.ioloop.IOLoop.instance().start()

# vim:set ft=python :