supervise.py 文件源码

def run(self):
        mutex.acquire()
        while True:

            Services = models.Service.query.all()
            for c in Services:
                if time.time() - float(c.createdtime) > 600:
                    removeServices(c.serviceid)
                    print "Stopped %s" % c.serviceid
            time.sleep(10)

        mutex.release()