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)