import threading
import time

# 线程类
# 使用一个类来管理线程,但这个类却不继承自 threadig.Thread 
# 这样的好处是这个类不再依赖于 threading.Thread 模块,而是独立地定义一段可并行运行的代码,可用于 multiprocessing 等模块
class ThreadGo:
 def __init__(self, name="", event=None, *args, **kwargs):
 self.args = args
 self.kwargs = kwargs
 self.name = name
 self.event = event
 self.go = True

 #终止线程
 def terminate(self):
 self.go = False

 #线程函数
 def run(self, times, txt):
 while self.go and times > 0:
 print(txt)
 times -= 1
 time.sleep(.5)
 self.event.set()

# 一个线程发出"事件"信号,一个或多个其他线程等待它。
event1 = threading.Event()
event2 = threading.Event()

# 创建线程(使用一个对象方法)
tg = ThreadGo(event=event1, times=5, txt="555")
th = threading.Thread(target=tg.run, name=tg.name, args=tg.args, kwargs=tg.kwargs)
# 启动线程
th.start()
event1.wait() # 阻塞等待

# 创建线程(使用一个对象方法)
tg = ThreadGo(event=event2, times=3, txt="333")
th = threading.Thread(target=tg.run, name=tg.name, args=tg.args, kwargs=tg.kwargs)
# 启动线程
th.start()
event2.wait() # 阻塞等待


print("exit...")