C++ 코루틴 | 비동기 프로그래밍 완벽 가이드 (C++20)
이 글의 핵심
C++ 코루틴 co_await·co_yield·co_return으로 비동기 프로그래밍. promise_type·coroutine_handle·제너레이터 구현. 스레드보다 가볍고, 수천 개의 코루틴도 가능합니다.
들어가며
C++20의 코루틴은 함수 실행을 일시 중단하고 재개할 수 있는 기능입니다. co_await, co_yield, co_return 키워드를 사용합니다. 비유로 말씀드리면, 일반 함수는 한 번 시작하면 끝까지 실행하는 것이고, 코루틴은 중간에 멈췄다가 나중에 이어서 실행할 수 있는 것입니다. 책을 읽다가 책갈피를 끼워 두고, 나중에 그 자리부터 다시 읽는 것과 비슷합니다.
이 글을 읽으면
- 코루틴의 개념과 사용법을 이해합니다
- promise_type과 coroutine_handle을 파악합니다
- 제너레이터와 비동기 작업을 구현합니다
- 스레드와의 차이를 확인합니다
실전 경험에서 배운 교훈
이 기술을 실무 프로젝트에 처음 도입했을 때, 공식 문서만으로는 알 수 없었던 많은 함정들이 있었습니다. 특히 프로덕션 환경에서 발생하는 엣지 케이스들은 로컬 개발 환경에서는 재현조차 되지 않았죠.
가장 어려웠던 점은 성능 최적화였습니다. 처음엔 “동작만 하면 되겠지”라고 생각했지만, 실제 사용자 트래픽이 몰리면서 병목 지점들이 하나씩 드러났습니다. 특히 데이터베이스 쿼리 최적화, 캐싱 전략, 에러 핸들링 구조 등은 여러 번의 장애를 겪으면서 개선해 나갔습니다.
이 글에서는 그런 시행착오를 통해 얻은 실전 노하우와, “이렇게 하면 안 된다”는 교훈들을 함께 정리했습니다. 특히 트러블슈팅 섹션은 실제 장애 대응 경험을 바탕으로 작성했으니, 비슷한 문제를 마주했을 때 참고하시면 도움이 될 것입니다.
코루틴 기초
코루틴 키워드
| 키워드 | 역할 |
|---|---|
| co_await | 비동기 작업 대기 |
| co_yield | 값 반환 후 일시 중단 |
| co_return | 코루틴 종료 |
기본 구조
#include <coroutine>
#include <iostream>
struct Task {
struct promise_type {
Task get_return_object() {
return Task{std::coroutine_handle<promise_type>::from_promise(*this)};
}
std::suspend_never initial_suspend() { return {}; }
std::suspend_never final_suspend() noexcept { return {}; }
void return_void() {}
void unhandled_exception() {}
};
using handle_type = std::coroutine_handle<promise_type>;
handle_type coro;
Task(handle_type h) : coro(h) {}
~Task() { if (coro) coro.destroy(); }
};
Task simpleCoroutine() {
std::cout << "코루틴 시작" << std::endl;
co_return;
}
int main() {
simpleCoroutine();
return 0;
}실전 구현
1) 제너레이터
#include <coroutine>
#include <iostream>
template<typename T>
struct Generator {
struct promise_type {
T current_value;
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 {}; }
std::suspend_always yield_value(T value) {
current_value = value;
return {};
}
void return_void() {}
void unhandled_exception() {}
};
using handle_type = std::coroutine_handle<promise_type>;
handle_type coro;
Generator(handle_type h) : coro(h) {}
~Generator() { if (coro) coro.destroy(); }
bool move_next() {
coro.resume();
return !coro.done();
}
T current_value() {
return coro.promise().current_value;
}
};
Generator<int> counter(int max) {
for (int i = 0; i < max; ++i) {
co_yield i;
}
}
int main() {
auto gen = counter(5);
while (gen.move_next()) {
std::cout << gen.current_value() << " "; // 0 1 2 3 4
}
std::cout << std::endl;
return 0;
}2) 피보나치 제너레이터
Generator<int> fibonacci(int n) {
int a = 0, b = 1;
for (int i = 0; i < n; ++i) {
co_yield a;
int temp = a;
a = b;
b = temp + b;
}
}
int main() {
auto fib = fibonacci(10);
while (fib.move_next()) {
std::cout << fib.current_value() << " ";
}
std::cout << std::endl; // 0 1 1 2 3 5 8 13 21 34
return 0;
}3) 범위 제너레이터
Generator<int> range(int start, int end, int step = 1) {
for (int i = start; i < end; i += step) {
co_yield i;
}
}
int main() {
auto gen = range(0, 10, 2);
while (gen.move_next()) {
std::cout << gen.current_value() << " "; // 0 2 4 6 8
}
std::cout << std::endl;
return 0;
}4) co_await
#include <coroutine>
#include <iostream>
struct Awaitable {
bool await_ready() { return false; }
void await_suspend(std::coroutine_handle<>) {}
void await_resume() {}
};
Task asyncFunction() {
std::cout << "시작" << std::endl;
co_await Awaitable{};
std::cout << "재개" << std::endl;
}고급 활용
1) 비동기 타이머
#include <chrono>
#include <coroutine>
#include <iostream>
#include <thread>
struct Timer {
std::chrono::milliseconds duration;
bool await_ready() { return false; }
void await_suspend(std::coroutine_handle<> h) {
std::thread([h, d = duration]() {
std::this_thread::sleep_for(d);
h.resume();
}).detach();
}
void await_resume() {}
};
Task asyncTask() {
std::cout << "시작" << std::endl;
co_await Timer{std::chrono::seconds(1)};
std::cout << "1초 후" << std::endl;
co_await Timer{std::chrono::seconds(1)};
std::cout << "2초 후" << std::endl;
}
int main() {
asyncTask();
std::this_thread::sleep_for(std::chrono::seconds(3));
return 0;
}2) 파일 라인 읽기
#include <fstream>
#include <iostream>
#include <string>
Generator<std::string> readLines(const std::string& filename) {
std::ifstream file(filename);
std::string line;
while (std::getline(file, line)) {
co_yield line;
}
}
int main() {
auto lines = readLines("input.txt");
while (lines.move_next()) {
std::cout << lines.current_value() << std::endl;
}
return 0;
}3) 코루틴 상태
std::coroutine_handle<> h = ...;
h.resume(); // 재개
h.done(); // 완료 여부
h.destroy(); // 파괴
h.promise(); // promise 접근성능 비교
코루틴 vs 스레드
#include <chrono>
#include <coroutine>
#include <iostream>
#include <thread>
#include <vector>
// 스레드
void threadExample() {
std::vector<std::thread> threads;
auto start = std::chrono::high_resolution_clock::now();
for (int i = 0; i < 1000; ++i) {
threads.emplace_back([]() {
// 작업
});
}
for (auto& t : threads) {
t.join();
}
auto end = std::chrono::high_resolution_clock::now();
auto time = std::chrono::duration_cast<std::chrono::milliseconds>(end - start).count();
std::cout << "스레드: " << time << "ms" << std::endl;
}
// 코루틴
Task coroutineExample() {
co_await std::suspend_always{};
}
void coroutineTest() {
auto start = std::chrono::high_resolution_clock::now();
std::vector<Task> tasks;
for (int i = 0; i < 1000; ++i) {
tasks.push_back(coroutineExample());
}
auto end = std::chrono::high_resolution_clock::now();
auto time = std::chrono::duration_cast<std::chrono::milliseconds>(end - start).count();
std::cout << "코루틴: " << time << "ms" << std::endl;
}결과:
| 방법 | 1000개 생성 시간 | 메모리 |
|---|---|---|
| 스레드 | 500ms | 8MB |
| 코루틴 | 5ms | 80KB |
| 결론: 코루틴이 100배 빠르고 100배 가벼움 |
실무 사례
사례 1: 비동기 HTTP 요청
#include <coroutine>
#include <iostream>
#include <string>
struct HttpResponse {
int status;
std::string body;
};
struct HttpAwaitable {
std::string url;
bool await_ready() { return false; }
void await_suspend(std::coroutine_handle<> h) {
// 비동기 HTTP 요청
std::thread([h, url = this->url]() {
// 실제로는 비동기 I/O
std::this_thread::sleep_for(std::chrono::milliseconds(100));
h.resume();
}).detach();
}
HttpResponse await_resume() {
return {200, "Response from " + url};
}
};
Task fetchData() {
std::cout << "요청 시작" << std::endl;
HttpResponse response = co_await HttpAwaitable{"https://example.com"};
std::cout << "상태: " << response.status << std::endl;
std::cout << "본문: " << response.body << std::endl;
}
int main() {
fetchData();
std::this_thread::sleep_for(std::chrono::seconds(1));
return 0;
}사례 2: 상태 머신
#include <coroutine>
#include <iostream>
enum class State {
Idle,
Running,
Paused,
Stopped
};
Generator<State> stateMachine() {
co_yield State::Idle;
co_yield State::Running;
co_yield State::Paused;
co_yield State::Running;
co_yield State::Stopped;
}
int main() {
auto sm = stateMachine();
while (sm.move_next()) {
State state = sm.current_value();
switch (state) {
case State::Idle:
std::cout << "대기 중" << std::endl;
break;
case State::Running:
std::cout << "실행 중" << std::endl;
break;
case State::Paused:
std::cout << "일시 정지" << std::endl;
break;
case State::Stopped:
std::cout << "정지" << std::endl;
break;
}
}
return 0;
}사례 3: 데이터 스트림 처리
#include <coroutine>
#include <iostream>
#include <vector>
Generator<int> filterEven(const std::vector<int>& data) {
for (int x : data) {
if (x % 2 == 0) {
co_yield x;
}
}
}
Generator<int> mapDouble(Generator<int>& gen) {
while (gen.move_next()) {
co_yield gen.current_value() * 2;
}
}
int main() {
std::vector<int> data = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
auto filtered = filterEven(data);
auto mapped = mapDouble(filtered);
while (mapped.move_next()) {
std::cout << mapped.current_value() << " "; // 4 8 12 16 20
}
std::cout << std::endl;
return 0;
}사례 4: 협력적 멀티태스킹
#include <coroutine>
#include <iostream>
#include <vector>
Task task1() {
for (int i = 0; i < 3; ++i) {
std::cout << "Task 1: " << i << std::endl;
co_await std::suspend_always{};
}
}
Task task2() {
for (int i = 0; i < 3; ++i) {
std::cout << "Task 2: " << i << std::endl;
co_await std::suspend_always{};
}
}
int main() {
auto t1 = task1();
auto t2 = task2();
for (int i = 0; i < 3; ++i) {
t1.coro.resume();
t2.coro.resume();
}
return 0;
}출력:
Task 1: 0
Task 2: 0
Task 1: 1
Task 2: 1
Task 1: 2
Task 2: 2트러블슈팅
문제 1: promise_type 누락
증상: 컴파일 에러
// ❌ promise_type 없음
struct Task {};
Task myCoroutine() {
co_return; // 에러: promise_type이 없음
}
// ✅ promise_type 정의
struct Task {
struct promise_type {
Task get_return_object() { /* ....*/ }
std::suspend_never initial_suspend() { return {}; }
std::suspend_never final_suspend() noexcept { return {}; }
void return_void() {}
void unhandled_exception() {}
};
};문제 2: 코루틴 핸들 파괴 누락
증상: 메모리 누수
// ❌ 메모리 누수
Generator<int> gen = counter(10);
// 소멸자에서 coro.destroy() 호출 안하면 누수
// ✅ 소멸자에서 파괴
~Generator() {
if (coro) coro.destroy();
}문제 3: 지역 변수 수명
증상: 댕글링 참조
// ❌ 댕글링 참조
Task bad() {
std::string str = "Hello";
std::string_view sv = str;
co_await std::suspend_always{};
std::cout << sv << std::endl; // str이 유효한가?
}
// ✅ 값 복사
Task good() {
std::string str = "Hello"; // 코루틴 프레임에 저장됨
co_await std::suspend_always{};
std::cout << str << std::endl; // 안전
}문제 4: 예외 처리
증상: 예외 전파 안 됨
// ❌ 예외 처리 누락
struct promise_type {
void unhandled_exception() {} // 예외 무시
};
// ✅ 예외 저장
struct promise_type {
std::exception_ptr exception;
void unhandled_exception() {
exception = std::current_exception();
}
};마무리
코루틴은 함수 실행을 일시 중단하고 재개할 수 있는 강력한 기능입니다.
핵심 요약
- 코루틴 키워드
- co_await: 비동기 작업 대기
- co_yield: 값 반환 후 일시 중단
- co_return: 코루틴 종료
- promise_type
- get_return_object
- initial_suspend / final_suspend
- yield_value / return_void
- unhandled_exception
- 성능
- 스레드보다 100배 가볍고 빠름
- 수천~수만 개의 코루틴 가능
- 컨텍스트 스위칭 비용 없음
- 주의사항
- promise_type 필수
- 코루틴 핸들 파괴 필수
- 지역 변수 수명 주의
- 예외 처리 필수
선택 가이드
| 상황 | 권장 | 이유 |
|---|---|---|
| 비동기 I/O | 코루틴 | 가벼움 |
| 제너레이터 | 코루틴 | 간결 |
| 상태 머신 | 코루틴 | 명확 |
| CPU 집약적 | 스레드 | 병렬 처리 |
코드 예제 치트시트
// 제너레이터
Generator<int> counter(int max) {
for (int i = 0; i < max; ++i) {
co_yield i;
}
}
// 비동기 작업
Task asyncTask() {
co_await someOperation();
}
// 코루틴 핸들
std::coroutine_handle<> h = ...;
h.resume();
h.done();
h.destroy();다음 단계
- future와 promise: C++ future와 promise
- 코루틴 완벽 가이드: C++20 Coroutines
- 비동기 프로그래밍: Complete Guide to C++20 Coroutines
참고 자료
- “C++20: The Complete Guide” - Nicolai M. Josuttis
- cppreference: https://en.cppreference.com/w/cpp/language/coroutines
- Lewis Baker’s blog: https://lewissbaker.github.io/
- cppcoro 라이브러리: https://github.com/lewissbaker/cppcoro 한 줄 정리: 코루틴은 함수 실행을 일시 중단하고 재개할 수 있는 기능으로, 스레드보다 100배 가볍고 비동기 프로그래밍을 동기 코드처럼 작성할 수 있게 한다.
같이 보면 좋은 글 (내부 링크)
이 주제와 연결되는 다른 글입니다.
- C++ future와 promise | “비동기” 가이드
- C++20 Coroutines 완벽 가이드 | 비동기 프로그래밍의 새 시대
- Complete Guide to C++20 Coroutines | A New Era of Asynchronous Programming
관련 글
심화 부록: 구현·운영 관점
이 부록은 앞선 본문에서 다룬 주제(「C++ 코루틴 | 비동기 프로그래밍 완벽 가이드 (C++20)」)를 구현·런타임·운영 관점에서 다시 압축합니다. 도메인별 세부 구현은 글마다 다르지만, 입력 검증 → 핵심 연산 → 부작용(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++ 코루틴 | 비동기 프로그래밍 완벽 가이드 (C++20)」)를 배포·운영 흐름에 맞춰 옮긴 체크리스트입니다. 도메인에 맞게 단계 이름만 바꿔 적용할 수 있습니다.
- 입력 계약 고정: 스키마·버전·최대 페이로드·타임아웃·에러 코드를 경계에 둔다.
- 핵심 경로 계측: 요청 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 순서를 권장합니다.
자주 묻는 질문 (FAQ)
Q. 이 내용을 실무에서 언제 쓰나요?
A. C++ 코루틴 완벽 가이드. co_await·co_yield·co_return으로 비동기 프로그래밍. promise_type·coroutine_handle·제너레이터 구현. 스레드보다 가볍고, 수천 개의 코루틴도 가… 실무에서는 위 본문의 예제와 선택 가이드를 참고해 적용하면 됩니다.
Q. 선행으로 읽으면 좋은 글은?
A. 각 글 하단의 이전 글 또는 관련 글 링크를 따라가면 순서대로 배울 수 있습니다. C++ 시리즈 목차에서 전체 흐름을 확인할 수 있습니다.
Q. 더 깊이 공부하려면?
A. cppreference와 해당 라이브러리 공식 문서를 참고하세요. 글 말미의 참고 자료 링크도 활용하면 좋습니다.
이 글에서 다루는 키워드 (관련 검색어)
C++, coroutine, C++20, 비동기, async 등으로 검색하시면 이 글이 도움이 됩니다.