Зачем нужно наследование от потока в питоне?

Question

[BoyFromDubai]

Может кто-то объяснить пожалуйста, зачем нужно наследование от потока в классе в python?
Я заметил это в модуле создание Р2Р-сети, в которой у клиента такой сети в листе хранятся объекты класса нового соединения со своими функциями, который наследован от threading.Thread (наверное эта информация избыточна, так как и без неё вопрос понятен)
И я не понимаю зачем нужно наследование от потока, если однажды эти потоки (объекты класса соединения) стартуются, а потом всякие методы данного класса вызываются все равно основным потоком (я выводил в этих методах название потока и там выводился основной поток)
Возможно не до конца понимаю механику потоков, но тем не менее

class NodeConnection(threading.Thread):
    def __init__(self, main_node, sock, id, host, port):
        self.sock = sock
        ...
    def send(self, data, encoding_type='utf-8', compression='none'):
        ...
        print(threading.current_thread().name)
        self.sock.sendall(data + self.EOT_CHAR)

class Node(threading.Thread):
    def __init__(self, host, port, id=None, callback=None, max_connections=0):
        self.nodes_outbound = []  # Nodes that we are connected to (US)->N

    def send_to_node(self, n, data, compression='none'):
        self.message_count_send = self.message_count_send + 1
        if n in self.nodes_inbound or n in self.nodes_outbound:
            n.send(data, compression=compression)

    def connect_with_node(self, host, port, reconnect=False):
        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.debug_print("connecting to %s port %s" % (host, port))
        sock.connect((host, port))
        thread_client = self.create_new_connection(sock, connected_node_id, host, port)
        thread_client.start()
        self.nodes_outbound.append(thread_client)

    def create_new_connection(self, connection, id, host, port):
        return NodeConnection(self, connection, id, host, port)

if __name__ == "__main__":
    node = Node()
    node.start(<host>, <port>)
    node.send_to_node(<n>, <data>)

То есть в классе NodeConnection в методе send выводится имя потока, то выводится MainThread
И поэтому я не понимаю, зачем в таких случаях вообще нужно наследование от потока, если по итогу все равно выводится имя главного потока (Я не все функции конечно вставил, только те, о которых шла речь в вопрос, дабы не наполнять вопрос лишней информацией)

Comments

[Алан Гибизов]

Для того, чтобы размещать вопрос в тэг python, не достаточно упомянуть о нем. Надо как минимум привести код на python, иначе это просто тэг-спам. См.п.3.1 Регламента.

[BoyFromDubai]

Алан Гибизов, Понял
Прошу прощения, не знал
Если не сложно, посмотрите пожалуйста, переделал вопрос

Answer 1

[Сергей П]

А для чего вы вырезали куски кода в методах? Там вполне может быть ответ на ваш вопрос, а нам как-то гадать надо на кофейной гузе?
К примеру в NodeConnection.__init__ вызывается наверно конструктор через super и туда вполне может быть передан target, а там может быть что угодно полезное и нужное, что обясняет ситуацию.
Почему не вставить полностью код для ясности?
UPD.
Наследование от треда здесь применяется потому, что каждый NodeConnection породит свой поток, в котором будет вычитываться свой инкапсулированный сокет) в который кажому инстансу NodeConnection передаются какие-то данные.
Можно было сделать просто отдельный класс и в него инкапсулировать и сокет и тред, но автор выбрал сокет инкапсулировать в тред.

В обзем NodeConnection - это тред с инкапсулированным сокетом для передачи ему данных из другого потока.

Comments

[BoyFromDubai]

Хорошо, сейчас вставлю весь код, там просто суммарно строк 700 получается

[Алан Гибизов]

BoyFromDubai, если не влезет, разместите на внешнем демонстрационном ресурсе вроде pastebin.

[BoyFromDubai]

Алан Гибизов, https://pastebin.com/nd6LUWYd
Только потом прочитал про этот ресурс, ссылку прикрепил

[BoyFromDubai]

Алан Гибизов, И то есть не понимаю зачем там наследование от потока, если функции вызываются основным итд
Плюс заметил функцию run, которая тоже нигде не вызывается никак

[Сергей П]

BoyFromDubai, смотря какие функции. Для передачи данных в потоки используются сокеты. send происходит из основного потока в дочерние, а дочерние потоки своим методом run вычитывают чанками из сокета переданные данные.

[Сергей П]

BoyFromDubai, Как это не вызывается? Именно она запускается в потоке. смотрите исходник threding

def start(self):
        """Start the thread's activity.

        It must be called at most once per thread object. It arranges for the
        object's run() method to be invoked in a separate thread of control.

        This method will raise a RuntimeError if called more than once on the
        same thread object.

        """

Это цитата из threding. Там написано что происходит при старте треда

[Сергей П]

BoyFromDubai, посмотрите в методе _bootstrap_inner в threading.
Там стартует .run(). Ну а стек вызовов проследите сами.

[BoyFromDubai]

Сергей Паньков, то есть, я правильно понимаю, что на этапе, который я выделил жирным, сам sendall вызывается основным потоком, а сама отправка данных - каким-то другим потоком?
Я не до конца понял наверное

elif isinstance(data, dict):
            try:
                if compression == 'none':
                    <b>self.sock.sendall(json.dumps(data).encode(encoding_type) + self.EOT_CHAR)</b>
                else:
                    data = self.compress(json.dumps(data).encode(encoding_type), compression)
                    if data != None:
                        self.sock.sendall(data + self.COMPR_CHAR + self.EOT_CHAR)

[Сергей П]

BoyFromDubai, Отправка данных происходит через сокет основным потоком.
А читают данные из своих сокетов уже дочерние потоки каждый в своём, каждый в "себе".
Ну я родил троих детей и вручил им каждому по смартфону, у кажого в смартфоне телеграм и чат со мной. Каждый их чат со мной - это сокет. Я пишу в чаты в своем потоке, а они читают в своем на ходу.

[Сергей П]

BoyFromDubai, Блин, ну в этом и смысл сокетов.
Я закину данные на передачу, они сразу легли в какой-то буфер и передаются уже операционной системой. С другого конца сокета их можно читать и это можно делать в любом потоке, тут это происходит в дочерних потоках. Чтение отдельно, а отправка отедльно.

[Сергей П]

Прочитайте что такое сокеты и зачем они нужны. рочитайте как следует исходники модуля threding и разберитесь что там зачем.
Почитайте как треды работают на уровне ОС, как сокеты работают на уровне ОС. Какие бывают сокеты.

[BoyFromDubai]

Сергей Паньков, понял
Спасибо за совет и за информацию, попробую разобраться тогда в этом всем
Спасибо!

[BoyFromDubai]

Сергей Паньков, да, вроде что-то понял, пойду поглубжу изучу вопрос
Спасибо!