C++20 Coroutines 완벽 가이드 | 비동기 프로그래밍의 새 시대
이 글의 핵심
C++20 Coroutines : 비동기 프로그래밍의 새 시대. C++20 Coroutines란?. 왜 필요한가·기본 키워드.
🎯 이 글을 읽으면 (읽는 시간: 22분)
TL;DR: C++20 코루틴으로 콜백 지옥을 탈출합니다. co_await, co_return, co_yield를 사용해 비동기 코드를 동기 코드처럼 깔끔하게 작성하는 방법을 배웁니다. 이 글을 읽으면:
- ✅ C++20 코루틴의 3가지 키워드 (co_await, co_return, co_yield) 완벽 이해
- ✅ 콜백 지옥 없이 우아한 비동기 코드 작성
- ✅ Generator 패턴으로 지연 평가 구현 실무 활용:
- 🔥 비동기 I/O 처리 (파일, 네트워크)
- 🔥 게임 엔진 (프레임 단위 실행)
- 🔥 대용량 데이터 스트리밍 난이도: 고급 | 실습 코드: 10개 | C++20 필수
C++20 Coroutines란? 왜 필요한가
문제 시나리오: 콜백 지옥
문제: 비동기 작업을 콜백으로 처리하면 코드가 중첩되어 가독성이 떨어집니다.
// 콜백 지옥
async_read_file("config.json", {
auto config = parse_json(content);
async_fetch_url(config.url, {
auto data = parse_response(response);
async_save_db(data, {
if (success) {
std::cout << "Done\n";
}
});
});
});
해결: Coroutines는 비동기 작업을 동기식 코드처럼 작성할 수 있게 해 줍니다.
// Coroutine으로 깔끔하게
Task<void> process() {
auto content = co_await async_read_file("config.json");
auto config = parse_json(content);
auto response = co_await async_fetch_url(config.url);
auto data = parse_response(response);
bool success = co_await async_save_db(data);
if (success) {
std::cout << "Done\n";
}
}
// 실행 예제
flowchart TD
subgraph callback[콜백 방식]
c1[async_read_file(callback1)]
c2["callback1: parse_json"]
c3[async_fetch_url(callback2)]
c4["callback2: parse_response"]
c5[async_save_db(callback3)]
end
subgraph coroutine[Coroutine 방식]
co1["co_await async_read_file"]
co2[parse_json]
co3["co_await async_fetch_url"]
co4[parse_response]
co5["co_await async_save_db"]
end
c1 --> c2 --> c3 --> c4 --> c5
co1 --> co2 --> co3 --> co4 --> co5
1. 기본 키워드
co_yield: 값 반환 후 중단
Generator<int> counter(int max) {
for (int i = 0; i < max; ++i) {
co_yield i; // i를 반환하고 중단
}
}
int main() {
auto gen = counter(5);
while (gen.next()) {
std::cout << gen.value() << '\n';
}
// 0 1 2 3 4
}
co_return: 최종 값 반환 후 종료
Task<int> compute() {
int result = 42;
co_return result; // 종료
}
co_await: 비동기 작업 대기
Task<std::string> fetch_data() {
auto response = co_await async_http_get("https://api.example.com/data");
co_return response;
}
2. Promise Type
Promise Type이란
Coroutine의 동작을 정의하는 타입입니다. Coroutine 함수의 반환 타입에 promise_type이 중첩되어 있어야 합니다.
struct MyCoroutine {
struct promise_type {
// 1. Coroutine 객체 생성
MyCoroutine get_return_object() {
return MyCoroutine{std::coroutine_handle<promise_type>::from_promise(*this)};
}
// 2. 초기 중단 여부
std::suspend_always initial_suspend() { return {}; } // 중단
// std::suspend_never initial_suspend() { return {}; } // 즉시 실행
// 3. 최종 중단 여부
std::suspend_always final_suspend() noexcept { return {}; }
// 4. 반환 처리
void return_void() {}
// void return_value(T value) { this->value = value; }
// 5. 예외 처리
void unhandled_exception() {
exception = std::current_exception();
}
// 6. yield 처리 (Generator용)
std::suspend_always yield_value(T value) {
this->value = value;
return {};
}
T value;
std::exception_ptr exception;
};
std::coroutine_handle<promise_type> handle;
~MyCoroutine() {
if (handle) handle.destroy();
}
};
3. Generator 구현
완전한 Generator
#include <coroutine>
#include <iostream>
#include <stdexcept>
template<typename T>
struct Generator {
struct promise_type {
T value;
std::exception_ptr exception;
Generator get_return_object() {
return Generator{std::coroutine_handle<promise_type>::from_promise(*this)};
}
std::suspend_always initial_suspend() { return {}; }
std::suspend_always final_suspend() noexcept { return {}; }
void return_void() {}
void unhandled_exception() {
exception = std::current_exception();
}
std::suspend_always yield_value(T v) {
value = v;
return {};
}
};
std::coroutine_handle<promise_type> handle;
explicit Generator(std::coroutine_handle<promise_type> h) : handle(h) {}
~Generator() {
if (handle) handle.destroy();
}
// 복사 금지
Generator(const Generator&) = delete;
Generator& operator=(const Generator&) = delete;
// 이동 가능
Generator(Generator&& other) noexcept : handle(other.handle) {
other.handle = nullptr;
}
Generator& operator=(Generator&& other) noexcept {
if (this != &other) {
if (handle) handle.destroy();
handle = other.handle;
other.handle = nullptr;
}
return *this;
}
bool next() {
if (!handle || handle.done()) return false;
handle.resume();
if (handle.promise().exception) {
std::rethrow_exception(handle.promise().exception);
}
return !handle.done();
}
T value() const {
return handle.promise().value;
}
};
// 사용 예시: 피보나치
Generator<int> fibonacci(int n) {
int a = 0, b = 1;
for (int i = 0; i < n; ++i) {
co_yield a;
int next = a + b;
a = b;
b = next;
}
}
int main() {
auto fib = fibonacci(10);
while (fib.next()) {
std::cout << fib.value() << ' ';
}
std::cout << '\n';
// 0 1 1 2 3 5 8 13 21 34
}
4. Task 구현 (비동기)
완전한 Task
#include <coroutine>
#include <exception>
#include <iostream>
template<typename T>
struct Task {
struct promise_type {
T value;
std::exception_ptr exception;
Task get_return_object() {
return Task{std::coroutine_handle<promise_type>::from_promise(*this)};
}
std::suspend_never initial_suspend() { return {}; } // 즉시 실행
std::suspend_always final_suspend() noexcept { return {}; }
void return_value(T v) {
value = v;
}
void unhandled_exception() {
exception = std::current_exception();
}
};
std::coroutine_handle<promise_type> handle;
explicit Task(std::coroutine_handle<promise_type> h) : handle(h) {}
~Task() {
if (handle) handle.destroy();
}
Task(const Task&) = delete;
Task& operator=(const Task&) = delete;
Task(Task&& other) noexcept : handle(other.handle) {
other.handle = nullptr;
}
T get() {
if (!handle.done()) {
handle.resume();
}
if (handle.promise().exception) {
std::rethrow_exception(handle.promise().exception);
}
return handle.promise().value;
}
bool done() const {
return handle.done();
}
};
// 사용 예시
Task<int> async_compute(int x) {
// 비동기 작업 시뮬레이션
co_return x * x;
}
int main() {
auto task = async_compute(10);
std::cout << "Result: " << task.get() << '\n'; // 100
}
5. Awaitable 객체
Awaitable 인터페이스
struct Awaitable {
// 1. 즉시 완료 여부
bool await_ready() const noexcept {
return false; // false면 중단
}
// 2. 중단 시 실행
void await_suspend(std::coroutine_handle<> h) const noexcept {
// 중단 로직 (스레드 풀에 작업 추가 등)
}
// 3. 재개 시 반환값
int await_resume() const noexcept {
return 42;
}
};
Task<int> example() {
int value = co_await Awaitable{};
co_return value;
}
실전 Awaitable: 타이머
#include <coroutine>
#include <chrono>
#include <thread>
struct SleepAwaitable {
std::chrono::milliseconds duration;
bool await_ready() const noexcept {
return duration.count() <= 0;
}
void await_suspend(std::coroutine_handle<> h) const {
std::thread([h, d = duration]() {
std::this_thread::sleep_for(d);
h.resume();
}).detach();
}
void await_resume() const noexcept {}
};
Task<void> delayed_print() {
std::cout << "Start\n";
co_await SleepAwaitable{std::chrono::seconds(1)};
std::cout << "After 1 second\n";
co_await SleepAwaitable{std::chrono::seconds(2)};
std::cout << "After 3 seconds total\n";
}
6. 자주 발생하는 문제와 해결법
문제 1: promise_type 누락
증상: error: unable to find the promise type for this coroutine.
원인: 반환 타입에 promise_type이 없음.
// ❌ 잘못된 사용
struct MyCoroutine {
// promise_type 없음
};
MyCoroutine func() {
co_return; // Error
}
// ✅ 올바른 사용
struct MyCoroutine {
struct promise_type {
MyCoroutine get_return_object() { return {}; }
std::suspend_never initial_suspend() { return {}; }
std::suspend_never final_suspend() noexcept { return {}; }
void return_void() {}
void unhandled_exception() {}
};
};
문제 2: 수명 관리
증상: 크래시, dangling handle. 원인: Coroutine handle을 제대로 파괴하지 않음.
// ❌ 잘못된 사용
struct Generator {
std::coroutine_handle<promise_type> handle;
// 소멸자 없음 → 메모리 누수
};
// ✅ 올바른 사용: RAII
struct Generator {
std::coroutine_handle<promise_type> handle;
~Generator() {
if (handle) handle.destroy();
}
// 복사 금지
Generator(const Generator&) = delete;
Generator& operator=(const Generator&) = delete;
// 이동 가능
Generator(Generator&& other) noexcept : handle(other.handle) {
other.handle = nullptr;
}
};
문제 3: 예외 처리
증상: Coroutine 내부 예외가 무시됨.
// ❌ 잘못된 사용
struct promise_type {
void unhandled_exception() {
// 아무것도 안 함 → 예외 손실
}
};
// ✅ 올바른 사용: 예외 저장 후 재발생
struct promise_type {
std::exception_ptr exception;
void unhandled_exception() {
exception = std::current_exception();
}
};
T get() {
if (handle.promise().exception) {
std::rethrow_exception(handle.promise().exception);
}
return handle.promise().value;
}
문제 4: co_await와 일반 함수 혼용
원인: co_await는 Coroutine 안에서만 사용 가능합니다.
// ❌ 잘못된 사용
void regular_function() {
co_await something(); // Error: not a coroutine
}
// ✅ 올바른 사용: Coroutine 함수
Task<void> coroutine_function() {
co_await something(); // OK
}
7. 프로덕션 패턴
패턴 1: 에러 처리
template<typename T>
struct Result {
std::variant<T, std::string> data;
bool has_value() const {
return std::holds_alternative<T>(data);
}
T value() const {
return std::get<T>(data);
}
std::string error() const {
return std::get<std::string>(data);
}
};
Task<Result<std::string>> safe_fetch(const std::string& url) {
try {
auto response = co_await async_http_get(url);
co_return Result<std::string>{response};
} catch (const std::exception& e) {
co_return Result<std::string>{std::string(e.what())};
}
}
패턴 2: Generator 체이닝
Generator<int> map(Generator<int> gen, int (*f)(int)) {
while (gen.next()) {
co_yield f(gen.value());
}
}
Generator<int> filter(Generator<int> gen, bool (*pred)(int)) {
while (gen.next()) {
int val = gen.value();
if (pred(val)) {
co_yield val;
}
}
}
Generator<int> range(int start, int end) {
for (int i = start; i < end; ++i) {
co_yield i;
}
}
int main() {
auto gen = range(0, 10);
auto doubled = map(std::move(gen), { return x * 2; });
auto evens = filter(std::move(doubled), { return x % 2 == 0; });
while (evens.next()) {
std::cout << evens.value() << ' ';
}
// 0 4 8 12 16
}
패턴 3: 비동기 타임아웃
template<typename T>
Task<std::optional<T>> with_timeout(Task<T> task, std::chrono::milliseconds timeout) {
auto start = std::chrono::steady_clock::now();
while (!task.done()) {
auto elapsed = std::chrono::steady_clock::now() - start;
if (elapsed > timeout) {
co_return std::nullopt; // 타임아웃
}
co_await std::suspend_always{};
}
co_return task.get();
}
8. 완전한 예제: 비동기 파일 처리
#include <coroutine>
#include <fstream>
#include <string>
#include <iostream>
template<typename T>
struct Task {
struct promise_type {
T value;
std::exception_ptr exception;
Task get_return_object() {
return Task{std::coroutine_handle<promise_type>::from_promise(*this)};
}
std::suspend_never initial_suspend() { return {}; }
std::suspend_always final_suspend() noexcept { return {}; }
void return_value(T v) { value = v; }
void unhandled_exception() { exception = std::current_exception(); }
};
std::coroutine_handle<promise_type> handle;
explicit Task(std::coroutine_handle<promise_type> h) : handle(h) {}
~Task() { if (handle) handle.destroy(); }
Task(const Task&) = delete;
Task(Task&& other) noexcept : handle(other.handle) {
other.handle = nullptr;
}
T get() {
if (!handle.done()) handle.resume();
if (handle.promise().exception) {
std::rethrow_exception(handle.promise().exception);
}
return handle.promise().value;
}
};
// 비동기 파일 읽기 (시뮬레이션)
Task<std::string> async_read_file(const std::string& path) {
std::ifstream file(path);
if (!file) {
throw std::runtime_error("File not found: " + path);
}
std::string content((std::istreambuf_iterator<char>(file)),
std::istreambuf_iterator<char>());
co_return content;
}
// 파일 처리 파이프라인
Task<int> process_files() {
try {
auto content1 = co_await async_read_file("file1.txt");
std::cout << "File1 size: " << content1.size() << '\n';
auto content2 = co_await async_read_file("file2.txt");
std::cout << "File2 size: " << content2.size() << '\n';
co_return content1.size() + content2.size();
} catch (const std::exception& e) {
std::cerr << "Error: " << e.what() << '\n';
co_return -1;
}
}
int main() {
auto task = process_files();
int total_size = task.get();
std::cout << "Total: " << total_size << '\n';
}
9. 성능 고려사항
Coroutine vs 스레드
| 항목 | Coroutine | 스레드 |
|---|---|---|
| 생성 비용 | 낮음 (수백 바이트) | 높음 (수 MB) |
| 컨텍스트 스위칭 | 빠름 (함수 호출 수준) | 느림 (커널 개입) |
| 동시 실행 | 협력적 (명시적 중단) | 선점적 (OS 스케줄링) |
| 적합 용도 | I/O 대기, Generator | CPU 집약 병렬 작업 |
| 요약: I/O 대기가 많은 비동기 작업은 Coroutine이 스레드보다 효율적입니다. 수천 개의 동시 연결을 처리하는 서버에서 유용합니다. |
정리
| 개념 | 설명 |
|---|---|
| Coroutine | 중단/재개 가능한 함수 |
| co_yield | 값 반환 후 중단 |
| co_return | 최종 값 반환 후 종료 |
| co_await | 비동기 작업 대기 |
| Promise Type | Coroutine 동작 정의 |
| Generator | 지연 평가 시퀀스 |
| Task | 비동기 작업 |
| C++20 Coroutines는 비동기 코드를 동기식으로 작성할 수 있게 해, 가독성과 유지보수성을 크게 향상시킵니다. |
FAQ
Q1: Coroutine vs async/await (다른 언어)?
A: C++의 Coroutine은 저수준 메커니즘입니다. Promise Type을 직접 구현해야 하지만, 그만큼 유연합니다. C#/JavaScript의 async/await는 언어에 내장된 고수준 기능입니다.
Q2: Generator vs std::ranges?
A: Generator는 지연 평가로 값을 하나씩 생성합니다. std::ranges는 기존 컨테이너를 뷰로 보는 것이고, Generator는 값을 동적으로 생성합니다.
Q3: co_await는 항상 중단하나요?
A: await_ready()가 true를 반환하면 중단하지 않고 즉시 await_resume()을 호출합니다. 이미 완료된 작업은 중단 없이 진행할 수 있습니다.
Q4: Coroutine은 스레드를 만드나요?
A: 아니요. Coroutine 자체는 단일 스레드에서 실행됩니다. await_suspend에서 스레드 풀에 작업을 넘기는 식으로 멀티스레드와 조합할 수 있습니다.
Q5: 컴파일러 지원은?
A:
- GCC 10+: 완전 지원 (
-fcoroutines) - Clang 14+: 완전 지원
- MSVC 2019+: 완전 지원 (
/await)
Q6: Coroutines 학습 리소스는?
A:
- cppreference - Coroutines
- “C++20: The Complete Guide” by Nicolai Josuttis
- Lewis Baker’s Coroutine Theory 한 줄 요약: C++20 Coroutines로 비동기 코드를 깔끔하게 작성할 수 있습니다. 다음으로 consteval을 읽어보면 좋습니다.
같이 보면 좋은 글 (내부 링크)
이 주제와 연결되는 다른 글입니다.
관련 글
- C++ 코루틴 |
- C++20 Coroutine | co_await·co_yield로
- C++ async & launch |
- C++20 Concepts 완벽 가이드 | 템플릿 제약의 새 시대
- C++20 consteval 완벽 가이드 | 컴파일 타임 전용 함수
심화 부록: 구현·운영 관점
이 부록은 앞선 본문에서 다룬 주제(「C++20 Coroutines 완벽 가이드 | 비동기 프로그래밍의 새 시대」)를 구현·런타임·운영 관점에서 다시 압축합니다. 도메인별 세부 구현은 글마다 다르지만, 입력 검증 → 핵심 연산 → 부작용(I/O·네트워크·동시성) → 관측의 흐름으로 장애를 나누면 원인 추적이 빨라집니다.
내부 동작과 핵심 메커니즘
flowchart TD A[입력·요청·이벤트] --> B[파싱·검증·디코딩] B --> C[핵심 연산·상태 전이] C --> D[부작용: I/O·네트워크·동시성] D --> E[결과·관측·저장]
sequenceDiagram participant C as 클라이언트/호출자 participant B as 경계(런타임·게이트웨이·프로세스) participant D as 의존성(API·DB·큐·파일) C->>B: 요청/이벤트 B->>D: 조회·쓰기·RPC D-->>B: 지연·부분 실패·재시도 가능 B-->>C: 응답 또는 오류(코드·상관 ID)
- 불변 조건(Invariant): 버퍼 경계, 프로토콜 상태, 트랜잭션 격리, FD 상한 등 단계별로 문장으로 적어 두면 디버깅 비용이 줄어듭니다.
- 결정성: 순수 층과 시간·네트워크·스케줄에 의존하는 층을 분리해야 테스트와 장애 분석이 쉬워집니다.
- 경계 비용: 직렬화, 인코딩, syscall 횟수, 락 경합, 할당·GC, 캐시 미스를 의심 목록에 둡니다.
- 백프레셔: 생산자가 소비자보다 빠를 때 버퍼·큐·스트림에서 속도를 줄이는 신호를 어디에 둘지 정의합니다.
프로덕션 운영 패턴
| 영역 | 운영 관점 질문 |
|---|---|
| 관측성 | 요청 단위 상관 ID, 에러율·지연 p95/p99, 의존성 타임아웃·재시도가 대시보드에 보이는가 |
| 안전성 | 입력 검증·권한·비밀·감사 로그가 코드 경로마다 일관적인가 |
| 신뢰성 | 재시도는 멱등 연산에만 적용되는가, 서킷 브레이커·백오프·DLQ가 있는가 |
| 성능 | 캐시·배치 크기·커넥션 풀·인덱스·백프레셔가 데이터 규모에 맞는가 |
| 배포 | 롤백 룬북, 카나리/블루그린, 마이그레이션·피처 플래그가 문서화되어 있는가 |
| 용량 | 피크 트래픽·디스크·FD·스레드 풀 상한을 주기적으로 검증하는가 |
스테이징은 데이터 양·네트워크 RTT·동시성을 프로덕션에 가깝게 맞출수록 재현율이 올라갑니다.
확장 예시: 엔드투엔드 미니 시나리오
앞선 본문 주제(「C++20 Coroutines 완벽 가이드 | 비동기 프로그래밍의 새 시대」)를 배포·운영 흐름에 맞춰 옮긴 체크리스트입니다. 도메인에 맞게 단계 이름만 바꿔 적용할 수 있습니다.
- 입력 계약 고정: 스키마·버전·최대 페이로드·타임아웃·에러 코드를 경계에 둔다.
- 핵심 경로 계측: 요청 ID, 단계별 지연, 외부 호출 결과 코드를 로그·메트릭·트레이스에서 한 흐름으로 본다.
- 실패 주입: 의존성 타임아웃·5xx·부분 데이터·락 대기를 스테이징에서 재현한다.
- 호환·롤백: 설정/마이그레이션/클라이언트 버전을 되돌릴 수 있는지 확인한다.
- 부하 후 검증: 피크 대비 p95/p99, 에러율, 리소스 상한, 알림 임계값을 점검한다.
handle(request):
ctx = newCorrelationId()
validated = validateSchema(request)
authorize(validated, ctx)
result = domainCore(validated)
persistOrEmit(result, idempotentKey)
recordMetrics(ctx, latency, outcome)
return result
문제 해결(Troubleshooting)
| 증상 | 가능 원인 | 조치 |
|---|---|---|
| 간헐적 실패 | 레이스, 타임아웃, 외부 의존성, DNS | 최소 재현 스크립트, 분산 트레이스·로그 상관관계, 재시도·서킷 설정 점검 |
| 성능 저하 | N+1, 동기 I/O, 락 경합, 과도한 직렬화, 캐시 미스 | 프로파일러·APM으로 핫스팟 확인 후 한 가지씩 제거 |
| 메모리 증가 | 캐시 무제한, 구독/리스너 누수, 대용량 버퍼, 커넥션 미반납 | 상한·TTL·힙/FD 스냅샷 비교 |
| 빌드·배포만 실패 | 환경 변수, 권한, 플랫폼 차이, lockfile | CI 로그와 로컬 diff, 런타임·이미지 버전 핀 |
| 설정 불일치 | 프로필·시크릿·기본값, 리전 | 스키마 검증된 설정 단일 소스와 배포 매트릭스 표준화 |
| 데이터 불일치 | 비멱등 재시도, 부분 쓰기, 캐시 무효화 누락 | 멱등 키·아웃박스·트랜잭션 경계 재검토 |
권장 순서: (1) 최소 재현 (2) 최근 변경 범위 축소 (3) 환경·의존성 차이 (4) 관측으로 가설 검증 (5) 수정 후 회귀·부하 테스트.
배포 전에는 git add → git commit → git push 후 npm run deploy 순서를 권장합니다.
이 글에서 다루는 키워드 (관련 검색어)
C++, coroutine, cpp20, async, generator, co_await 등으로 검색하시면 이 글이 도움이 됩니다.