[Flask] ボタンでスレッドの開始と終了をコントロールさせる方法

Question

やりたいこと

フォーム入力でなにかしらwebサービスのログイン情報を登録。
登録した情報の一覧画面で、アカウント情報の横にはボタンがあって、
開始ボタンを押したら何かしらの処理をスレッドで実行。
終了ボタンを押したら処理を停止させる。

という感じのwebアプリを作りたいと思っています。

行き詰まっていること

スレッドの開始は簡単にできたのですが、
いま動いている特定のスレッドを指定して停止させる方法がわかりません。

質問

以下のソースで、
/start?name=○○○
にアクセスしたらスレッドを実行。
/stop?name=○○○
にアクセスしたら、スタート時にgetで送ったnameのスレッドを停止させる。

これを実現するにはどのようにコーディングすればいいでしょうか？

from flask import Flask, request
from threading import Thread, Semaphore
from datetime import datetime
import time

app = Flask(__name__)
sem = Semaphore(5)


def main(semaphore, name):
    with semaphore:
        while True:
            time.sleep(1)
            print(name + ': ' + str(datetime.today()))


@app.route('/')
def index():
    return 'index'


@app.route('/start')
def start():
    name = request.args.get('name')
    if name:
        th = Thread(target=main, args=(sem, name))
        th.start()
        return name + ' started.'
    return 'スレッド名を入力してください。'


@app.route('/stop')
def stop():
    name = request.args.get('name')
    if name:
        # 停止する処理
        return name + ' stopped.'
    return '停止したいスレッド名を入力してください。'


if __name__ == '__main__':
    app.run()

Answer 1

以下で実現できました。

from flask import Flask, request
import threading
from datetime import datetime
import time

app = Flask(__name__)


class StoppableThread(threading.Thread):
    def __init__(self, target, name):
        super(StoppableThread, self).__init__(target=target, name=name)
        self._stop = threading.Event()

    def run(self):
        while not self._stop.is_set():
            time.sleep(1)
            print(threading.currentThread().getName() + ': ' + str(datetime.today()))

    def stop(self):
        self._stop.set()

    def stopped(self):
        return self._stop.isSet()


def get_thread_by_name(name):
    threads = threading.enumerate()
    for thread in threads:
        if thread.getName() == name:
            return thread
    return None


@app.route('/')
def index():
    return 'index'


@app.route('/start')
def start():
    name = request.args.get('name')
    if name:
        if not get_thread_by_name(name):
            th = StoppableThread(target=StoppableThread, name=name)
            th.start()
            return name + ' started.'
        return '同名のスレッドが存在します'
    return 'スレッド名を入力してください。'


@app.route('/stop')
def stop():
    name = request.args.get('name')
    if name:
        thread = get_thread_by_name(name)
        if thread:
            thread.stop()
            return name + ' stopped.'
    return '停止したいスレッド名を入力してください。'


if __name__ == '__main__':
    app.run()