确保所有线程都关闭或强行关闭线程？

import threading

class MyThread(threading.Thread):
    _lock = threading.Lock()
    _active_threads = 0

    def __init__(self):
        with MyThread._lock:
            MyThread._active_threads += 1

    def run(self):
        # 在这里执行您的任务
        pass

    def join(self):
        super().join()
        with MyThread._lock:
            MyThread._active_threads -= 1

t1 = MyThread()
t2 = MyThread()

t1.start()
t2.start()

t1.join()
t2.join()

t = MyThread()
t.start()

# 强行关闭线程
t._stop()