12345678910111213141516171819202122232425262728293031323334 |
- import sys
- import time
- import threading
- import pwd
- import signal
- from appBoot.logUtil import LogUtil
- from dataAnalysisService.service.serviceOfDataAnalysis import ServiceOfDataAnalysis
- logUtil=LogUtil()
- logger=logUtil.getLogger()
- class DaemonService:
- def __init__(self):
- self.stop_event = threading.Event()
- self.service=ServiceOfDataAnalysis()
- def run(self):
- while not self.stop_event.is_set():
- logger.info("Daemon is running...")
- self.service.run()
- def start(self):
- self.stop_event.clear()
- thread = threading.Thread(target=self.run)
- thread.start()
- def stop(self):
- self.stop_event.set()
- def status(self):
- if self.stop_event.is_set():
- logger.info("Daemon is not running.")
- else:
- logger.info("Daemon is running.")
|