How to organize parallel task execution using multithreading and asyncio (worker pool, task queue, gather)?