heartbeat demo

heartbeat.py

import threading

def foo():
  alive = True
  c = threading.Condition()
  def heartbeater():
    heartbeat_interval = 60
    heartbeat_threshold = 10
    c.acquire()
    while alive:
      send_heartbeat(heartbeat_interval * heartbeat_threshold)
      c.wait(heartbeat_interval)
    c.release()
  t = threading.Thread(target=heartbeater)
  t.deamon = True
  t.start()
  for i in range(100):
    # do the real job
    os.sleep(10)
  c.acquire()
  c.notify()
  c.release()
  t.join()