Всем привет!Не могу разобраться с многопоточностью в Python.
У меня есть 2 скрипта. Один - главный, второй - содержит функцию, которую я хочу запустить параллельно главному процессу.
Main Script:
import threading
#мой подключаемый скрипт
import train_liveness as train
t = Thread(target=train.train)
while True:
read += 1
........
if (read == 25):
t.start()
Function train из train_liveness
def train()
.......
return True
Пока что получилось сделать только заморозку главного процесса до момента завершения второго потока с помощью .join().
Но моя задача немного другая - запустить именно параллельно, чтобы функция выполнялась независимо от главного скрипта.
Еще проблема, я хочу получить свое значение из функции, которое она вернет - True. Это поможет мне понять, что функция завершилась и я могу закрыть поток.
И да, не нашла функцию для закрытия потока. После отработки функции поток не убивается и в следующий раз, когда я пытаюсь запустить t.start(), он, естественно, ругается, что поток уже запущен.
Подскажите, как я могу решить эту проблему? Если не сложно, приведите пример кода, а не ссылки на документацию. Спасибо!
start
вызывать нельзя, нужно создать новый поток.join
. Данные из потока передавайте через очередь. В главном скрипте периодически вызывайтеget_nowait
для получения данных из потока. Или используйте Executor и назначьте функцию обратного вызова наfuture
.