Похоже в точку и видимо оно как раз таки выполняется и очень много раз. Там и происходит утечка. Хм, а
как сказать потокам ждать новых задач и не закрываться? В отдельном потоке крутиться функция которая подкидывает новые задачи в Queue
Коллеги, извиняюсь за задержку, на свежую голову обобщил код в сниппет следующего вида:
https://paste.ofcode.org/eB3AJb2nVxxTzzYkkC5Nnp
https://paste.ofcode.org/eB3AJb2nVxxTzzYkkC5NnpРешение:
while que.qsize() > 0:
time.sleep(0.25)
task = que.get()
threader.submit(job, task)
Моя неопытность. Благодарю за наводки!
Правда тухнут потоки. Остался вопрос... Sleep может не совпадать со скоростью подачи новых тасков