Mercurial > repos > shellac > sam_consensus_v3
diff env/lib/python3.9/site-packages/galaxy/util/monitors.py @ 0:4f3585e2f14b draft default tip
"planemo upload commit 60cee0fc7c0cda8592644e1aad72851dec82c959"
author | shellac |
---|---|
date | Mon, 22 Mar 2021 18:12:50 +0000 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/env/lib/python3.9/site-packages/galaxy/util/monitors.py Mon Mar 22 18:12:50 2021 +0000 @@ -0,0 +1,51 @@ +import logging +import threading + +from .sleeper import Sleeper +from .web_compat import register_postfork_function + +log = logging.getLogger(__name__) + +DEFAULT_MONITOR_THREAD_JOIN_TIMEOUT = 5 + + +class Monitors: + + def _init_monitor_thread(self, name, target_name=None, target=None, start=False, config=None): + self.monitor_join_sleep = getattr(config, "monitor_thread_join_timeout", DEFAULT_MONITOR_THREAD_JOIN_TIMEOUT) + self.monitor_join = self.monitor_join_sleep > 0 + self.monitor_running = True + + if target is not None: + assert target_name is None + monitor_func = target + else: + target_name = target_name or "monitor" + monitor_func = getattr(self, target_name) + self.sleeper = Sleeper() + self.monitor_thread = threading.Thread(name=name, target=monitor_func) + self.monitor_thread.setDaemon(True) + self._start = start + register_postfork_function(self.start_monitoring) + + def _init_noop_monitor(self): + self.sleeper = None + self.monitor_join = False + + def start_monitoring(self): + if self._start: + self.monitor_thread.start() + + def stop_monitoring(self): + self.monitor_running = False + + def _monitor_sleep(self, sleep_amount): + self.sleeper.sleep(sleep_amount) + + def shutdown_monitor(self): + self.stop_monitoring() + if self.sleeper is not None: + self.sleeper.wake() + if self.monitor_join: + log.debug("Joining monitor thread") + self.monitor_thread.join(self.monitor_join_sleep)