import subprocess
from concurrent.futures import ThreadPoolExecutor
from pathlib import Path


def task(name: str) -> subprocess.Popen:
    logfile = Path(name).parent.parent / "logs" / (Path(name).name + ".log")
    return subprocess.Popen(f'C:\\Windows\\System32\\cmd.exe /C "{name} 1"', stdout=logfile.open("w")).wait()


def run(base_dir: str, max: int = 5) -> None:
    files = [str(f) for f in Path(base_dir).glob("*.bat") if not f.name.startswith("_")]

    with ThreadPoolExecutor(max_workers=max) as executor:
        executor.map(task, files)


if __name__ == "__main__":
    run("C:\\GlobalCube\\System\\OPTIMA\\SQL\\batch")