python-asyncio-new.py

from queue import Queue
from asyncio import get_running_loop, wait, run
from concurrent.futures import ThreadPoolExecutor

async def main():
    tasks = []
    loop = get_running_loop()
    
    ftpQueue = Queue()
    jsonQueue = Queue()

    with ThreadPoolExecutor(max_workers=20) as executor:
        for item in fetch_names():
            tasks.append(loop.run_in_executor(executor, master, ..., ftpQueue, jsonQueue))

        await wait(tasks)

run(main())