DI
Size: a a a
2021 August 11
DI
Да вот же
BB
точно. ну я помню, что оно там было.
VT
Коллеги, не подскажите по утечке памяти в threads, если передавать callable функцию с аргами в queue. При time.sleep память в алгебраической прогрессии по ~100 мб/сек утекает, причем без реальной нагрузки, принты и слипы.
A
Если все так просто как ты говоришь, покажи код
АП
Вот пускай коллеги и подсказывают.
DI
+100
BB
что такое алгебраическая прогрессия
VT
def employer():
for task in [(payload, arg), (payload, arg), (payload, arg)]:
que.put(task)
def payload(arg):
time.sleep(10)
def worker():
task = que.get()
task = payload(task)
return task
with concurrent.futures.ThreadPoolExecutor(max_workers=4) as threader:
threader.sumbit(employer)
while que.qsize() > 0:
future = threader.submit(worker)
future.add_done_callback(callback)
Вот на sleep происходит утечка. Это не полный код, но смысл такойm
с таким кодом тоже утечки наблюдаешь?
VT
😂 алгебра больше нравилась чем арифметика
DK
1^k, 2^k, 3^k, ...
НВ
Это точно рабочий прототип для воспроизведения проблемы?
VT
@Niccolum нет, пока не получилось воспроизвести с чистого листа, пишу сейчас, понимаю что это что-то базовое, типа не делаю join или result
Z
task_done() не вижу..
A
условие
while que.qsize() > 0: волшебное. может не выполниться ни разу.A
так он и join на очереди не делает. а task_done это просто счетчик.
2021 August 12
S
Моё уважение аватарке
YS
как боженька написал!