queue threading

Author: AstinCHOI

6장_파이썬_고급/1_threading_with_queue.py

@@ -0,0 +1,33 @@
+import queue
+import threading
+
+q = queue.Queue()
+
+def worker(num):
+    while True:
+        item = q.get()
+        if item is None:
+            break
+        # 작업을 처리한다.
+        print(f"스레드 {num+1} : 처리 완료 {item}")
+        q.task_done()
+
+if __name__ == '__main__':
+    num_worker_threads = 5
+    threads = []
+    for i in range(num_worker_threads):
+        t = threading.Thread(target=worker, args=(i,))
+        t.start()
+        threads.append(t)
+    
+    for item in range(20):
+        q.put(item)
+    
+    # 모든 작업이 끝날때까지 대기한다(block).
+    q.join()
+    
+    # 워커 스레드를 종료한다(stop).
+    for i in range(num_worker_threads):
+        q.put(None)
+    for t in threads:
+        t.join()