@@ -14,17 +14,29 @@ from lightmon import config from lightmon import jobs class RunningJob(object): + """ + A job that is running in memory + """ + def __init__(self, job): self.job = job self.running_since = time.time() self.thread = None def start(self): - thread = threading.Thread(target=self.job.run, + "Start a new job as a thread" + thread = threading.Thread(target=self.job.start, name=self.job.name) self.thread = thread thread.start() + def stop(self): + """ + Kills a thread but first tries to free all the resources that have been + locked within the thread + """ + raise NotImplementedError + class Client(object): """ @@ -62,7 +74,7 @@ class Client(object): for runjob in self.runjobs: if (now - runjob.running_since) > MAX_CHECK_EXECUTION_TIME: # thread has exceeded execution time - pass + runjob.stop() # reschedule ourselves self.scheduler.enter(config.SELF_CHECK_EVERY, 1, self.controller, ()) lightmon/client/client.py e7b1be1005f92020ece4d71e5cc3abe4e273d8be Ivan Giuliani giuliani.v@gmail.com http://github.com/kratorius/lightmon/commit/be5233e009fa2bf4c37bf94c288a2e2d93dae776 be5233e009fa2bf4c37bf94c288a2e2d93dae776 2009-11-06T14:56:43-08:00 2009-11-06T14:56:43-08:00 Added the stop mechanism (not done yet) to the RunningJob 617cfe83f1f83343f47758e4ef81cf745475c103 Ivan Giuliani giuliani.v@gmail.com