C++ condition_variable로 스레드 간 통신 구현하기

🔔 condition_variable이란?

C++에서 condition_variable은 멀티스레드 환경에서
스레드 간의 통신을 가능하게 하는 동기화 도구입니다.
특정 조건이 충족될 때까지 하나의 스레드가 기다리고,
다른 스레드가 해당 조건을 충족시키면 알림을 보내 기다리던 스레드를 깨워주는 방식으로 작동합니다.

쉽게 말해, 생산자-소비자 패턴처럼 데이터를 처리하는 순서나 조건이 중요한 상황에서
스레드 간의 작업 흐름을 조율할 수 있도록 도와주는 것이죠.
이를 통해 불필요한 CPU 점유를 줄이고, 효율적인 리소스 활용이 가능해집니다.

• 📌조건이 충족될 때까지 스레드를 자동으로 대기 상태로 전환
• 🔔다른 스레드가 조건을 만족시켜 notify_one 또는 notify_all로 알림 전송
• 🧠mutex와 함께 사용해 race condition 방지

이러한 방식은 단순한 무한 루프 기반의 polling 기법보다 훨씬 효율적이며,
대기 중인 스레드는 CPU를 소모하지 않고 잠들어 있게 됩니다.
결국 condition_variable은 스레드 간 협업을 가능하게 해주는 똑똑한 대기 시스템이라고 할 수 있어요.

🔒 wait과 notify의 동작 원리

condition_variable을 사용할 때 핵심이 되는 함수는 wait(), notify_one(), notify_all()입니다.
이들은 각각 스레드가 조건을 기다리도록 하거나, 조건이 충족되었음을 알려주는 역할을 합니다.

wait() 함수는 내부적으로 mutex와 함께 사용되며,
조건이 충족될 때까지 현재 스레드를 자동으로 블로킹 상태로 전환시킵니다.
이때 unique_lock을 사용하는 것이 일반적입니다.

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void consumer() {
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, []{ return ready; });
    std::cout << "데이터 소비 완료" << std::endl;
}

void producer() {
    {
        std::lock_guard<std::mutex> lock(mtx);
        ready = true;
    }
    cv.notify_one();
}

위 예제에서 소비자 스레드는 조건 ready == true가 될 때까지 기다리고,
생산자 스레드가 notify_one()을 통해 알림을 주면 블로킹이 해제되어 다음 작업을 수행하게 됩니다.

알림 방식에는 notify_one()과 notify_all()이 있습니다.
전자는 하나의 대기 스레드만 깨우고, 후자는 모든 대기 스레드를 깨우므로 상황에 따라 적절히 선택해야 합니다.

📦 생산자-소비자 패턴 적용 예제

condition_variable이 가장 자주 활용되는 대표적인 구조는 바로 생산자-소비자 패턴입니다.
하나의 스레드는 데이터를 생성하고, 다른 스레드는 그 데이터를 처리하는 구조인데,
동기화가 적절히 이루어지지 않으면 race condition이나 무한 대기 같은 문제가 발생할 수 있죠.

다음은 condition_variable을 이용해 안전하게 생산자-소비자 관계를 구현한 코드 예제입니다.

#include <iostream>
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>

std::queue<int> buffer;
std::mutex mtx;
std::condition_variable cv;
const unsigned int MAX_SIZE = 5;

void producer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, [] { return buffer.size() < MAX_SIZE; });
        buffer.push(i);
        std::cout << "생산: " << i << std::endl;
        cv.notify_all();
    }
}

void consumer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, [] { return !buffer.empty(); });
        int value = buffer.front();
        buffer.pop();
        std::cout << "소비: " << value << std::endl;
        cv.notify_all();
    }
}

이 코드에서는 생산자는 버퍼가 가득 찼을 때 대기하고, 소비자는 버퍼가 비었을 때 대기합니다.
모든 동작은 condition_variable을 통해 동기화되며,
데이터가 손실되거나 중복 소비되는 문제를 방지합니다.

이러한 패턴은 로그 수집기, 데이터 스트림 처리기, 네트워크 패킷 큐 등 다양한 분야에 활용되며,
스레드 간 협업을 위한 필수 구조라고 해도 과언이 아닙니다.

⛓️ lock_guard와 unique_lock의 차이

C++에서 mutex를 사용할 때는 보통 lock_guard 또는 unique_lock을 사용합니다.
둘 다 자동으로 mutex를 잠그고 범위를 벗어나면 자동으로 풀어주는 RAII 방식의 도구이지만,
condition_variable과 함께 사용할 경우에는 unique_lock을 반드시 사용해야 합니다.

• 🔐lock_guard는 단순하고 빠르지만 lock 해제 제어가 불가능
• 🔄unique_lock은 lock을 해제하거나 재획득할 수 있어 유연함
• 📌condition_variable::wait()은 반드시 unique_lock을 요구

wait() 함수는 내부적으로 mutex를 잠깐 해제하고 다시 잠그는 동작을 수행하는데,
이러한 동작은 lock_guard로는 제어할 수 없기 때문에 unique_lock이 필요합니다.

정리하자면, 단순한 임계영역 보호에는 lock_guard가,
복잡한 동기화 또는 condition_variable을 동반한 로직에는 unique_lock이 적합합니다.
상황에 맞게 두 도구를 구분해서 사용하는 것이 C++ 멀티스레드 프로그래밍의 핵심입니다.

⚠️ deadlock 방지와 예외 처리 팁

condition_variable을 사용할 때 가장 주의해야 할 점은 데드락(deadlock)과 예외 처리입니다.
mutex와 wait, notify가 서로 꼬이면 스레드가 영원히 깨어나지 않는 상황이 발생할 수 있고,
예외가 발생했을 때 적절히 unlock하지 않으면 리소스 누수로 이어질 수 있습니다.

• 🔄mutex는 항상 RAII 방식으로 관리 (unique_lock 또는 lock_guard)
• 📛wait 조건 람다로 spurious wakeup 방지
• 🧯예외가 발생할 가능성이 있는 구간은 try-catch로 감싸기

C++의 condition_variable::wait()은 내부적으로 while 루프와 조건 검사를 동반해야 안전합니다.
조건 없이 wait만 호출하면 잘못된 시점에 깨어나는 spurious wakeup이 발생할 수 있기 때문이죠.

또한 notify는 반드시 mutex unlock 이후에 호출해야 하며,
예외가 발생했을 때도 notify가 누락되지 않도록 로직을 정리해두는 것이 좋습니다.
이러한 기본 수칙만 잘 지켜도 데드락은 대부분 예방할 수 있습니다.

❓ 자주 묻는 질문 (FAQ)