KnowHow

import threading
import queue
import time

# 共有Queueの作成
task_queue = queue.Queue()

# Threadクラスを継承したワーカークラス
class WorkerThread(threading.Thread):
    def __init__(self, name, task_queue):
        super().__init__()
        self.name = name
        self.task_queue = task_queue

    def run(self):
        while True:
            try:
                # キューからタスクを取得（3秒待ってもなければ終了）
                task = self.task_queue.get(timeout=3)
            except queue.Empty:
                print(f"{self.name}: キューが空なので終了します")
                break
            print(f"{self.name}: {task} を処理中")
            time.sleep(1)  # 処理のシミュレーション
            self.task_queue.task_done()

# キューにタスクを追加
for i in range(10):
    task_queue.put(f"タスク{i}")

# 複数のワーカースレッドを生成して開始
threads = []
for i in range(3):
    t = WorkerThread(f"Worker-{i}", task_queue)
    t.start()
    threads.append(t)

# 全てのタスクが完了するのを待つ
task_queue.join()

# スレッドの終了を待機
for t in threads:
    t.join()

print("全てのタスクが完了しました")