使用thread模块

Jacket777 · Jacket777 · commit 0b506145ac46 · 2023-05-11T22:15:49.000+08:00
diff --git a/ch15_threading/part05_cookbook/code0102_启动与停止线程.py b/ch15_threading/part05_cookbook/code0102_启动与停止线程.py
@@ -0,0 +1,26 @@
+
+import time
+from threading import Thread
+
+
+class CountDownTask:
+    def __init__(self):
+        self._running = True
+
+    def terminate(self):
+        self._running = False
+
+    def run(self, n):
+        while self._running and n > 0:
+            print('T-minus', n)
+            n -= 1
+            time.sleep(5)
+
+
+c = CountDownTask()
+t = Thread(target=c.run, args=(10,))
+t.start()
+c.terminate()  # Signal termination
+t.join()   # Wait for actual termination (if needed)
+print("=====end=====")
+
diff --git a/ch15_threading/part05_cookbook/code01_启动与停止线程.py b/ch15_threading/part05_cookbook/code01_启动与停止线程.py
@@ -0,0 +1,31 @@
+# Code to execute in an independent thread
+import time
+from threading import Thread
+
+
+def countdown(n):
+    while n > 0:
+        print("T-minus: {}".format(n))
+        n -= 1
+        time.sleep(10)
+
+
+
+if __name__ == '__main__':
+    # 1. create a thread
+    t = Thread(target=countdown, args=(10,))
+    # t = Thread(target=countdown, args=(10,), daemon=True) # 将当前线程设置为后台线程，后台线程会在主线终止时自动销毁
+    # 2 start a thread
+    t.start()
+    # 3 thread state
+    # while True:
+    #     if t.is_alive():
+    #         print("Still running\n")
+    #         time.sleep(3)
+    #     else:
+    #         print('Completed\n')
+    #         break
+    #t.join()
+
+
+
