Закрывается ли в таком случае поток и невредно ли так делать?

Question

[old_stalin]

Использую библиотеку threading
Сначала на ОЧЕНЬ абстрактном примере покажу как мой код выглядит:

import threading
def a():
    a = 5
    thread = threading.Thread(target=b, args=(a,), daemon=True)
    thread.start()
    return
def b(a):
    while True:
        a+=1
        if a == 1000000:
            print("Hello world")
            break
    return
a()

так вот, вопрос - закрывается ли в таком случае поток? И если нет, не вредно ли его так оставлять?
P.s пожалуйста не пишите ответы или комменты по типу: "Код ерунда" и тд. В своей проге я обязательно должен сначала запустить поток, а потом уже сделать return, никак иначе.

Answer 1

[Сергей П]

Вы плохо сформулировали вопрос.
В конкретно этом коде тред даже не запустится. Нигде не вызывается a().
Если в конце модуля с этим куском кода все же вызвать a(), то тут не будет ожидания выполнения треда. а значит успеет он выполнится или нет, и на сколько успеет - вопрос везения.
В любом случае при закрытии интерпретатора все ресурсы высвобождаются, а значит всё закроется.
Однако, полагаю, вопрос ваш немного глубже и сложнее, ведь вы сами себя обманули абстрактностью этого примера. При каких обстоятельствах у вас запускается этот тред и что происходит в коде после запуска вы не указали.

Comments

[old_stalin]

я имел ввиду заканчивается ли выполнение thread = threading.Thread(target=b, args=(a,), daemon=True), когда я в функции b() делаю return

[Сергей Горностаев]

old_stalin, нет, не заканчивается. И нет, это не вредно, если вы не плодите безконтрольно большое количество потоков.

[old_stalin]

Сергей Горностаев, просто я делаю сайт, и там происходит проверка оплаты, и получается так, что он все время перед тем как сделать return redirec(url) запускает процесс проверки

[old_stalin]

и получается в долгосрочном периоде будет очень много незакрытых потоков(

[Сергей П]

old_stalin, почему это не закрытых?
Вот в исходниках:

def start_new_thread(function, args, kwargs=None): # real signature unknown; restored from __doc__
    """
    start_new_thread(function, args[, kwargs])
    (start_new() is an obsolete synonym)
    
    Start a new thread and return its identifier.  The thread will call the
    function with positional arguments from the tuple args and keyword arguments
    taken from the optional dictionary kwargs.  The thread exits when the
    function returns; the return value is ignored.  The thread will also exit
    when the function raises an unhandled exception; a stack trace will be
    printed unless the exception is SystemExit.
    """
    pass

По идее завершение или исключение в функции b() должно останавливать тред.

[old_stalin]

Сергей Паньков, ну просто тут написали

нет, не заканчивается.

[old_stalin]

я и подумал

[Сергей П]

old_stalin, тут надо, всё же, послушать доводы Сергей Горностаев, ведь каждый может ошибаться, даже я.=)

[old_stalin]

Сергей Паньков, вы на самом деле правильно сказали, только для библиотеки _tread, а я пользовался threading, но сейчас поменял на _tread)

[Сергей П]

old_stalin, не надо ничего менять. _thread испольузется внутри threading.
_thread - это враппер вокруг встроенной сишной библиотеки.
Нет никакого смысла использовать треды на таком низком уровне, когда есть хорошая объектная обертка в виде threading.

[Сергей Горностаев]

old_stalin, очень важно то, на чём вы делаете этот сайт и какую библиотеку используете для обработки платежей. Потому что многие фреймворки и библиотеки не являются потокобезопасными и могут глючить.

[Сергей П]

Сергей Горностаев, важное замечание. Да и глупо, к примеру, на FastAPI делать на тредах такие вещи

[old_stalin]

Сергей Горностаев, киви апи для управления аккаунтом и pyqiwip2p для создания p2p платежей

Answer 2

[old_stalin]

Вот в исходниках:

def start_new_thread(function, args, kwargs=None): # real signature unknown; restored from __doc__
    """
    start_new_thread(function, args[, kwargs])
    (start_new() is an obsolete synonym)
    
    Start a new thread and return its identifier.  The thread will call the
    function with positional arguments from the tuple args and keyword arguments
    taken from the optional dictionary kwargs.  The thread exits when the
    function returns; the return value is ignored.  The thread will also exit
    when the function raises an unhandled exception; a stack trace will be
    printed unless the exception is SystemExit.
    """
    pass

По идее завершение или исключение в функции b() должно останавливать тред.