initialize the workers for the airports and destroy them during shutdown

This commit is contained in:
Sven Czarnian
2021-09-02 20:59:41 +02:00
parent 479d7b2d44
commit 744ad71b6c

View File

@@ -8,6 +8,7 @@ from aman.com.Euroscope import Euroscope
from aman.config.AircraftPerformance import AircraftPerformance from aman.config.AircraftPerformance import AircraftPerformance
from aman.config.Airport import Airport from aman.config.Airport import Airport
from aman.config.System import System from aman.config.System import System
from aman.sys.Worker import Worker
class AMAN: class AMAN:
def findConfigPath(): def findConfigPath():
@@ -27,6 +28,7 @@ class AMAN:
self.systemConfig = None self.systemConfig = None
self.aircraftPerformance = None self.aircraftPerformance = None
self.receiver = None self.receiver = None
self.workers = []
configPath = AMAN.findConfigPath() configPath = AMAN.findConfigPath()
@@ -50,7 +52,11 @@ class AMAN:
print('Parsing planner configuration for ' + icao) print('Parsing planner configuration for ' + icao)
airportConfig = Airport(file, icao) airportConfig = Airport(file, icao)
# TODO initialize the planner thread # initialize the worker thread
worker = Worker(icao, airportConfig)
worker.start()
self.workers.append(worker)
print('Starter worker for ' + icao)
# create the EuroScope receiver # create the EuroScope receiver
self.receiver = Euroscope(configPath, self.systemConfig.Server) self.receiver = Euroscope(configPath, self.systemConfig.Server)
@@ -59,3 +65,6 @@ class AMAN:
if None != self.receiver: if None != self.receiver:
del self.receiver del self.receiver
self.receiver = None self.receiver = None
for worker in self.workers:
worker.stop()