並列に実行してる複数のwhileループを止める方法を教えてください

Question

実現したいこと

並列に複数実行しているwhileループを　ctrl+Cキーあるいは別のキーを入力すると停止するようにしたい
また、GPIOモジュールを使っているので　停止後に　GPIO.cleanup()　を実行したい

前提

whileループの入った複数のdef関数を　threadingで同時に実行したいのですが
止め方がわかりません
処理すべてを一度に停止して、その後　GPIO.cleanup()　を実行する方法を教えてください

該当のソースコード

def loop_1 ():
    while True:
        ###省略

def loop_2 ():
    while True:  
        ###省略

if __name__ == "__main__":
    thread_1 = threading.Thread(target=loop_1)
    thread_2 = threading.Thread(target=loop_2)

    thread_1.start()
    thread_2.start()

試したこと

def loop_1 ():
    while True:
        try:
        except KeyboardInterrupt:
            break

KeyboardInterruptを実行しても
処理が続行してしまいます

補足情報（FW/ツールのバージョンなど）

環境　raspberrypi４bからThonny Python IDEで実行
（私はまだclassを理解できていないので
出来れば　使わないやりかたでお願いします）

Comments

[退会済みユーザー]

どちらも簡単ですが、KeyboardInterruptを受け取る方法と、スレッドを停止する方法はそれぞれ別の質問にすべきです。
それぞれ出来るようになってから、組み合わせを考えましょう。

Answer 1

gloal 変数を参照してそのフラグがTrueになったら、スレッドを終了するようにしてはいかがでしょうか。
フラグは、シグナルハンドラー内でTrueにします。
シグナルハンドラーはSIGINTを捕捉します。
Clrl-C を押下するとSIGINTが発生します。
print("end")の箇所で、GPIO.cleanup()をすれば良いかと。
SIGINTの代わりにSIGUSR1などを使用しても構いません。（その場合はCtrl-Cでなく、SIGUSR1をこのプロセスに送出します）

import threading
import signal
G_flg = False
def loop_1 ():
    global G_flg
    while True:
        if G_flg == True:
            print("loop_1")
            break
        ###

def loop_2 ():
    global G_flg
    while True:
        if G_flg == True:
            print("loop_2")
            break
        ###

def handler(signum,frame):
    global G_flg
    G_flg = True
    print("handler",signum)


if __name__ == "__main__":
    signal.signal(signal.SIGINT, handler)
    thread_1 = threading.Thread(target=loop_1)
    thread_2 = threading.Thread(target=loop_2)

    thread_1.start()
    thread_2.start()

    thread_1.join()
    thread_2.join()
    print("end")

Answer 2

すっごく単純だけど

import threading

run = True

def loop_1 ():
    while run:
        print(1)
    print("1: terminated")

def loop_2 ():
    while run:  
        print(2)
    print("2: terminated")

if __name__ == "__main__":
    thread_1 = threading.Thread(target=loop_1)
    thread_2 = threading.Thread(target=loop_2)

    thread_1.start()
    thread_2.start()
    input() # なんか入力したら
    run = False # 止まる
    print("bye.")

Answer 3

そもそもの考え方が逆です
ループを中断する方法、ではなく、
ループを中断できるようなコードを書く、ってことです。

実際の実装例は他の回答を参照。

Answer 4

以下は ctypes.pythonapi.PyThreadState_SetAsyncExc() 使う方法です。

import threading
import ctypes
import time

def loop_1():
    try:
        while True:
          time.sleep(0.1)
    except:
        print('terminate loop1')

def loop_2():
    try:
        while True:
          time.sleep(0.1)
    except:
        print('terminate loop2')

def terminate_threads(*threads):
    for th in threads:
        tid = [tid for tid, thr in threading._active.items() if thr is th]
        if tid:
            ctypes.pythonapi.PyThreadState_SetAsyncExc(
                ctypes.c_long(tid[0]), ctypes.py_object(ValueError))
            th.join()

if __name__ == "__main__":
    thread_1 = threading.Thread(target=loop_1)
    thread_2 = threading.Thread(target=loop_2)

    thread_1.start()
    thread_2.start()

    time.sleep(2)
    terminate_threads(thread_1, thread_2)