back to ThreadPoolExecutor

import sys

import time

from pathlib import Path

from concurrent.futures import ProcessPoolExecutor, as_completed

from concurrent.futures import ThreadPoolExecutor, as_completed

sys.path.append("./ivas-processing-scripts")

from ivas_processing_scripts.audiotools.wrappers.bs1770 import get_loudness

    progressbar_update(0, total, width=50)

    with ProcessPoolExecutor(max_workers=8) as executor:

    with ThreadPoolExecutor() as executor:

        # Submit all tasks

        futures = {

            executor.submit(process_output_file, *task): task[0] for task in tasks