aman-sys/aman/sys/Worker.py

#!/usr/bin/env python

from threading import Thread, Lock
import time

from aman.config.Airport import Airport

class Worker(Thread):
    def __init__(self, icao : str, configuration : Airport):
        Thread.__init__(self)

        self.stopThread = None
        self.icao = icao
        self.configuration = configuration
        self.arrivalRoutes = configuration.gngData.arrivalRoutes
        self.updateLock = Lock()
        self.reportQueue = {}

    def stop(self):
        self.stopThread = True

    def run(self):
        counter = 0

        while None == self.stopThread:
            time.sleep(1)
            counter += 1
            if 0 != (counter % 60):
                continue

            # TODO handle the report queue and update internal information
            # TODO execute planning, etc.
            continue