파이썬 스레딩 프로그래밍 Condition wait notify notify_all 조건 대기 패턴 완벽 가이드

🔗 Condition 객체란 무엇인가

파이썬에서 threading.Condition 객체는 멀티스레드 환경에서 동기화를 위해 사용되는 핵심 도구입니다.
일반적으로 Lock이나 RLock 같은 락 객체와 함께 사용되며, 특정 조건을 만족할 때까지 스레드가 대기(wait)하도록 만들 수 있습니다.
이렇게 하면 여러 스레드가 공유 자원에 무분별하게 접근하는 문제를 막고, 정해진 조건이 충족되었을 때만 안전하게 다음 단계로 넘어갈 수 있습니다.

예를 들어, 생산자-소비자 패턴을 구현할 때 생산자가 데이터를 생성하기 전에는 소비자가 기다리게 하고, 생산자가 데이터를 생성하면 대기 중인 소비자에게 알림을 보낼 수 있습니다.
이때 Condition은 단순한 락 이상의 역할을 하며, 스레드 간의 협업을 가능하게 하는 중요한 매개체가 됩니다.

📌 Condition 객체의 기본 구조

Condition은 내부적으로 Lock이나 RLock을 포함하고 있으며, acquire()와 release()를 통해 락을 관리합니다.
스레드가 특정 조건을 기다릴 때는 wait() 메서드를 호출해 락을 놓고 대기하며, 다른 스레드가 조건을 만족시키면 notify()나 notify_all()을 통해 다시 깨어나 실행을 이어갑니다.

import threading

condition = threading.Condition()

def worker():
    with condition:
        print("스레드 대기 중...")
        condition.wait()
        print("조건이 충족되어 작업 재개!")

def notifier():
    with condition:
        print("조건 충족! 알림 보냄")
        condition.notify()

위 예제에서 worker 스레드는 wait()을 호출해 대기 상태에 들어가고, notifier 스레드가 notify()를 실행하면 다시 깨어나서 이후 코드를 실행합니다.
이 패턴이 바로 조건 대기의 기본적인 작동 원리입니다.

🛠️ wait 메서드의 동작 원리

Condition 객체의 wait() 메서드는 스레드를 특정 조건이 만족될 때까지 대기 상태로 전환시키는 역할을 합니다.
이 메서드를 호출하면 스레드는 내부적으로 보유한 락을 풀고(wait 상태로 전환), 다른 스레드가 조건을 만족시켜 알림을 줄 때까지 멈춰 있게 됩니다.
이 과정에서 중요한 점은 wait()을 호출하기 전에 반드시 Condition 객체의 락을 확보해야 한다는 것입니다.

즉, 스레드는 다음 순서로 동작합니다.
락을 획득 → wait() 호출 → 락을 풀고 대기 → notify() 또는 notify_all() 신호를 받으면 다시 락을 획득하고 실행을 이어감.
이 과정 덕분에 공유 자원에 대한 안정적인 접근이 보장됩니다.

📌 wait() 사용 예제

import threading
import time

condition = threading.Condition()
shared_data = None

def consumer():
    global shared_data
    with condition:
        while shared_data is None:
            print("소비자: 데이터가 준비될 때까지 대기...")
            condition.wait()
        print(f"소비자: 데이터 소비 = {shared_data}")

def producer():
    global shared_data
    time.sleep(2)
    with condition:
        shared_data = "생산된 데이터"
        print("생산자: 데이터 준비 완료, 알림 전송")
        condition.notify()

위 코드에서 소비자 스레드는 데이터가 None일 경우 wait()을 호출해 대기 상태에 들어갑니다.
이후 생산자가 데이터를 준비하고 notify()를 호출하면 소비자가 깨어나 데이터를 안전하게 소비합니다.

⚙️ notify와 notify_all 차이점

Condition 객체는 대기 중인 스레드를 깨우기 위해 notify() 또는 notify_all() 메서드를 제공합니다.
두 메서드는 비슷해 보이지만, 실제 동작 방식에는 중요한 차이가 있습니다.

notify()는 대기 중인 스레드 중 단 하나만 깨웁니다.
반면 notify_all()은 대기 중인 모든 스레드에게 신호를 보내 실행을 재개하게 만듭니다.
따라서 어떤 메서드를 선택하느냐에 따라 시스템의 동작 성능과 자원 활용 방식이 달라집니다.

📌 notify()와 notify_all() 비교

📌 사용 예제

import threading

condition = threading.Condition()

def worker(i):
    with condition:
        print(f"작업자 {i}: 대기 중")
        condition.wait()
        print(f"작업자 {i}: 실행 재개")

def notifier_all():
    with condition:
        print("모든 작업자에게 알림")
        condition.notify_all()

def notifier_one():
    with condition:
        print("작업자 하나에게만 알림")
        condition.notify()

위 코드에서 notify()를 쓰면 단 하나의 스레드만 깨어나고, notify_all()을 쓰면 동시에 여러 스레드가 깨어납니다.
여러 소비자가 동시에 준비된 데이터를 처리해야 하는 경우라면 notify_all()이 적합하고, 한 번에 하나의 소비자만 처리하도록 하고 싶다면 notify()가 더 효율적입니다.

🔌 조건 대기 패턴 활용 예제

Condition 객체는 단순히 wait과 notify를 사용하는 수준을 넘어, 복잡한 멀티스레드 환경에서 안전하게 자원을 공유할 수 있도록 다양한 패턴으로 활용됩니다.
그 대표적인 예가 바로 생산자-소비자(Producer-Consumer) 패턴입니다.
이 패턴에서는 생산자가 데이터를 만들어 큐에 넣고, 소비자가 큐에서 데이터를 꺼내 처리하는 구조를 갖습니다.

만약 Condition을 사용하지 않는다면 소비자가 데이터가 없는데도 큐를 확인하며 불필요하게 CPU를 낭비하거나, 생산자가 데이터를 덮어써 버리는 문제가 생길 수 있습니다.
Condition을 활용하면 데이터가 준비되었을 때만 소비자가 동작하게 만들 수 있어 효율적이고 안전한 동기화가 가능합니다.

📌 생산자-소비자 패턴 구현

import threading
import time
import random

condition = threading.Condition()
queue = []

def consumer():
    while True:
        with condition:
            while not queue:
                print("소비자: 큐가 비어있어 대기 중...")
                condition.wait()
            item = queue.pop(0)
            print(f"소비자: {item} 소비 완료")

def producer():
    while True:
        time.sleep(random.randint(1, 3))
        item = random.randint(1, 100)
        with condition:
            queue.append(item)
            print(f"생산자: {item} 생산, 소비자에게 알림")
            condition.notify()

위 예제에서 소비자는 큐가 비어 있으면 wait()을 호출해 대기 상태로 들어갑니다.
생산자가 새로운 아이템을 큐에 넣으면 notify()를 호출하여 소비자를 깨우고, 소비자는 해당 아이템을 꺼내 처리합니다.
이런 구조 덕분에 불필요한 자원 낭비 없이 효율적인 데이터 흐름이 유지됩니다.

• 🛠️소비자는 조건이 충족될 때까지 wait() 상태 유지
• ⚙️생산자는 데이터 생성 후 notify() 실행
• 🔌여러 소비자가 있다면 notify_all() 활용 가능

💡 실무에서 자주 쓰이는 동기화 패턴

파이썬 Condition 객체는 단순히 학습용 예제를 넘어서 실제 서비스와 애플리케이션 개발 과정에서 매우 자주 활용됩니다.
특히 다수의 스레드가 동시에 동작하면서도 순서를 보장하거나 자원 충돌을 방지해야 할 때 중요한 역할을 합니다.

대표적으로 사용되는 패턴에는 순차 실행 보장, 버퍼 제어, 이벤트 대기 등이 있습니다.
이런 패턴을 통해 실무에서는 안정적이고 예측 가능한 동작을 구현할 수 있습니다.

📌 순차 실행 패턴

여러 개의 스레드가 동시에 실행되더라도 특정 순서에 따라 실행을 이어가야 할 때 Condition이 유용합니다.
예를 들어 스레드 A가 끝나야 스레드 B가 시작되는 로직을 구현할 수 있습니다.

import threading

condition = threading.Condition()
flag = False

def task_a():
    global flag
    with condition:
        print("작업 A 실행 완료")
        flag = True
        condition.notify_all()

def task_b():
    with condition:
        while not flag:
            condition.wait()
        print("작업 B 실행 시작")

📌 버퍼 제어 패턴

생산자-소비자 패턴의 확장 형태로, 특정 버퍼 크기를 초과하지 않도록 제어하는 방법입니다.
버퍼가 가득 찼을 때 생산자는 대기하고, 소비자가 데이터를 꺼낼 때까지 기다린 후 다시 생산을 시작합니다.

💬 실무에서는 메시지 큐, 로그 처리 시스템, 데이터 파이프라인 등에서 이 패턴이 자주 활용됩니다.

📌 이벤트 대기 패턴

특정 이벤트가 발생해야만 다음 단계로 진행되는 경우에도 Condition을 활용할 수 있습니다.
예를 들어 서버가 초기화 완료될 때까지 모든 작업 스레드를 대기시키는 구조가 가능합니다.

❓ 자주 묻는 질문 (FAQ)