【Python】threadingをクラス化して「バックグラウンド処理」を実装する方法

import threading
import time

# --- 1. スレッドを継承したクラスの定義 ---
class NetworkReceiver(threading.Thread):
    """
    バックグラウンドで通信（受信）を待ち続けるクラス
    """
    def __init__(self, target_name):
        super(NetworkReceiver, self).__init__()
        self.target_name = target_name
        self.is_running = True
        self.daemon = True  # メイン終了時にこのスレッドも強制終了させる設定

    def run(self):
        """
        start()を呼ぶと、このメソッドの中身が別スレッドで動き出す
        """
        print(f"  [Thread] {self.target_name}：受信待ちを開始しました...")
        
        while self.is_running:
            # 本来はここで socket.recv() などの通信待ちを行う
            # 今回はデモとして3秒ごとに「データ受信」を表示
            time.sleep(3)
            print(f"\n  [Thread] ★重要★ {self.target_name}からデータを受信しました！")

        print(f"  [Thread] {self.target_name}：スレッドを安全に終了しました。")

    def stop(self):
        """スレッドを外部から止めるためのメソッド"""
        self.is_running = False


# --- 2. メイン側での呼び出し（メインロジック） ---
if __name__ == "__main__":
    print("=== メイン処理：開始 ===")

    # スレッドクラスのインスタンス化
    receiver = NetworkReceiver("TCP-Server")

    # スレッドを開始（内部で run() が呼ばれる）
    receiver.start()

    # メインスレッドでの別の仕事
    try:
        for i in range(1, 11):
            print(f"[Main] 重い計算やUI更新などを実行中... ({i}/10)")
            # スレッド側が受信待ちをしていても、メインは止まらずに進む
            time.sleep(1)

    except KeyboardInterrupt:
        print("\n[Main] ユーザーにより中断されました")

    finally:
        # スレッドを安全に停止させる
        print("=== メイン処理：スレッドに停止命令を出します ===")
        receiver.stop()
        receiver.join()  # スレッドが完全に終わるのを待つ

    print("=== メイン処理：すべて完了しました ===")