class Worker(Thread):
def __init__(self, queue: Queue, id: int):
super().__init__(name=str(id))
self.queue = queue
def run(self) -> None:
while not self.queue.empty():
item = self.queue.get() ----- ➊
print(f"스레드 {current_thread().name}: "
f"메시지 {item}를 처리함")
time.sleep(2)
def main(thread_num: int) -> None:
➋
q = Queue()
for i in range(10):
q.put(i)