Mercurial > repos > shellac > sam_consensus_v3
comparison 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 |
comparison
equal
deleted
inserted
replaced
-1:000000000000 | 0:4f3585e2f14b |
---|---|
1 import logging | |
2 import threading | |
3 | |
4 from .sleeper import Sleeper | |
5 from .web_compat import register_postfork_function | |
6 | |
7 log = logging.getLogger(__name__) | |
8 | |
9 DEFAULT_MONITOR_THREAD_JOIN_TIMEOUT = 5 | |
10 | |
11 | |
12 class Monitors: | |
13 | |
14 def _init_monitor_thread(self, name, target_name=None, target=None, start=False, config=None): | |
15 self.monitor_join_sleep = getattr(config, "monitor_thread_join_timeout", DEFAULT_MONITOR_THREAD_JOIN_TIMEOUT) | |
16 self.monitor_join = self.monitor_join_sleep > 0 | |
17 self.monitor_running = True | |
18 | |
19 if target is not None: | |
20 assert target_name is None | |
21 monitor_func = target | |
22 else: | |
23 target_name = target_name or "monitor" | |
24 monitor_func = getattr(self, target_name) | |
25 self.sleeper = Sleeper() | |
26 self.monitor_thread = threading.Thread(name=name, target=monitor_func) | |
27 self.monitor_thread.setDaemon(True) | |
28 self._start = start | |
29 register_postfork_function(self.start_monitoring) | |
30 | |
31 def _init_noop_monitor(self): | |
32 self.sleeper = None | |
33 self.monitor_join = False | |
34 | |
35 def start_monitoring(self): | |
36 if self._start: | |
37 self.monitor_thread.start() | |
38 | |
39 def stop_monitoring(self): | |
40 self.monitor_running = False | |
41 | |
42 def _monitor_sleep(self, sleep_amount): | |
43 self.sleeper.sleep(sleep_amount) | |
44 | |
45 def shutdown_monitor(self): | |
46 self.stop_monitoring() | |
47 if self.sleeper is not None: | |
48 self.sleeper.wake() | |
49 if self.monitor_join: | |
50 log.debug("Joining monitor thread") | |
51 self.monitor_thread.join(self.monitor_join_sleep) |