state_machine.py

from concurrent.futures import ThreadPoolExecutor
from time import sleep, time


def runner(state, working, wait_to_start):
    print(f'start {state}')
    sleep(wait_to_start * 60)
    stop_time = time() + (working * 60)
    while stop_time >= time():
        print(state)
        sleep(0.2)


def main():
    estados = [
        ('a', 2, 0), 
        ('b', 4, 1), 
        ('c', 4, 30)
        ]
    with ThreadPoolExecutor(max_workers=len(estados)+1) as pool:
        pool_futures = []
        for state, working, wait_to_start in estados:
            f = pool.submit(runner, state, working, wait_to_start)
            pool_futures.append(f)
        while not all(map(lambda x: x.done(), pool_futures)):
            sleep(0.1)
    
    
if __name__ == "__main__":
    main()