Использование сервиса в качестве контроллера с несколькими потоками.
Один поток (основной) должен синхронизировать и ставить команды в очередь и использовать служебную структуру win32 для связи, регистрации в системе и т. Д.
Другой поток (рабочий) должен ожидать команды из очереди и выполнять их. Если вы выполняете произвольный код как отдельные процессы, вы можете порождать их из рабочего потока и просто читать результаты после их завершения и очищать.
Таким образом, когда приходит остановка, ваш основной поток зарегистрирует его для работника в его очереди, который проснется и попытается дать сигнал другим процессам выйти, немного подождать и очистить или принудительно завершить их. .
Обновление:
Ниже приведен пример концепции того, как вы могли бы иметь сервис, который всегда отзывчив и работает столько времени, сколько необходимо. Каждый работник может бросить
...
import threading
...
class InterruptedException(Exception):
pass
class WorkerThread(threading.Thread):
def __init__(self, controller):
self._controller = controller
self._stop = threading.Event()
super(WorkerThread, self).__init__()
def stop(self):
self._stop.set()
def stopped(self):
return self._stop.isSet()
def run(self):
try:
# Insert the code you want to run as a service here
# rather than do "execfile(.../.../blah)" simply do:
# You can have your code throw InterruptedException if your code needs to exit
# Also check often if self.stopped and then cleanly exit
import your_file
your_file.main()
# if code in another module is not yours or cannot check often if it should stop then use multiprocessing which will spawn separate processes that you can terminate then from here when you need to stop and return
# in that case simply block here on self._stop.wait()
except InterruptedException as exc:
# We are forcefully quitting
pass
except Exception as e:
# Oh oh, did not anticipate this, better report to Windows or log it
finally:
# Close/release any connections, handles, files etc.
# OK, we can stop now
win32event.SetEvent(self._controller)
def __init__(self, args):
win32serviceutil.ServiceFramework.__init__(self, args)
self.hWaitStop = win32event.CreateEvent(None, 0, 0, None)
self.hWaitDone = win32event.CreateEvent(None, 0, 0, None)
def SvcDoRun(self):
import servicemanager
servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE,
servicemanager.PYS_SERVICE_STARTED,(self._svc_name_, ''))
worker = WorkerThread(self.hWaitDone)
worker.start()
while True:
# Wait for service stop signal
rc = win32event.WaitForMultipleObjects([self.hWaitStop, self.hWaitDone], win32event.INFINITE)
# Check to see if self.hWaitStop happened as part of Windows Service Management
if rc == 0:
# Stop signal encountered
servicemanager.LogInfoMsg(self._svc_name_ + " - STOPPED!") #For Event Log
break
if rc == 1:
# Wait until worker has fully finished
worker.join()
# Determine from worker state if we need to start again (because run finished)
# Or do whatever
if not worker.need_to_start_again():
break
worker.start()