Привет, не особо пойму, как устроена многопоточность с помощью модуля

Question

$Императорская Моль 🕊-\0$ Императорская Моль 🕊 \0

Привет, не особо пойму, как устроена многопоточность с помощью модуля

threading
Допустим, у меня есть функция, довольно большая, которая делает много разной работы с сетью, результат своей работы записывает в глобальную переменную
Я так понял, что все переменные этой функции спокойно делятся между потоками (тут я вообще в шоке был)
И как быть в таком случае? Все переменные заворачивать в threading.local()?

#backend #programming #python #russian

0

28.06.2022

5 ответов

19 просмотров

$Императорская Моль 🕊-\0$ Императорская Моль 🕊 \0 Автор вопроса

Sergey Gureev
нет, "внутренние" переменные функции, которую ты з...

В функции (которая работает в 200+ потоках) есть локальные переменные, с ними вроде как всё ок, проблема с локальным массивом, он почему-то общий для всех потоков Помимо этого есть глобальный массив Глобальный массив никак не связан с локальным массивом То есть, если я уберу использование глобального массива, то и локальный массив будет по-настоящему локальным?

0

28.06.2022

$Императорская Моль 🕊-\0$ Императорская Моль 🕊 \0 Автор вопроса

Я передал на concurent.futures, ничего не изменилось, ниже минимальный пример, проблема на нём сохраняется. https://pastebin.com/nuL1zw4Q

0

28.06.2022

Sergey Gureev

Императорская Моль 🕊 \0
Я передал на concurent.futures, ничего не изменило...

нужно вот так делать class MyClass: def __init__(self): self.arr = [] тогда для каждого нового экземпляра этого класса будет создан новый пустой список arr иначе, все твои объекты используют один и тот же список, который находится на уровне атрибутов класса, а не объекта

0

28.06.2022

$Императорская Моль 🕊-\0$ Императорская Моль 🕊 \0 Автор вопроса

Sergey Gureev
нужно вот так делать class MyClass: def __init...

Огромное спасибо!

0

28.06.2022

Sergey Gureev · Accepted Answer

нет, "внутренние" переменные функции, которую ты запускаешь в отдельном потоке доступны только для нее а вот если ты запускаешь несколько таких функций в нескольких потоках, а потом работаешь с какой-то общей, глобальной переменной, то тебе нужно использовать блокировку ну или перепиши свой код так, чтобы использовать concurrect.futures.ThreadPoolExecutor, там у тебя абстракция уже не "потоки" а "фьючерсы" (мне это нравится больше ,чем называть их футурами), и они могут возвращать результаты через return как обычная функция отличие лишь в том, что для получения результата из фьючерса тебе надо его явно об этом попросить через my_future.result() этот вызов заблокирует поток выполнения до тех пор пока, вьючерс не будет завершен

170 похожих чатов

Привет, не особо пойму, как устроена многопоточность с помощью модуля

5 ответов

Похожие вопросы