folly::fibers 분석 — M:N stackful coroutine
한 줄 요약:
folly::fibers는 boost.context 기반 stackful coroutine으로 동기적으로 보이는 코드를 비동기 실행한다. C++20 coroutine보다 코드 변환이 가볍지만 stack 메모리를 쓴다.
#동기 — stackful coroutine이 필요한 이유
folly::Future 체인은 강력하지만 코드 모양이 비동기적이다.
folly::SemiFuture<Result> process(int id) { return fetchUser(id) .deferValue([](User u) { return fetchOrders(u); }) .deferValue([](std::vector<Order> orders) { return summarize(orders); });}같은 로직을 동기 스타일로 쓰고 싶다.
Result process(int id) { User u = fetchUserSync(id); auto orders = fetchOrdersSync(u); return summarize(orders);}C++20 coroutine은 이를 위해 co_await을 도입했다. Folly fibers는 그 이전부터 같은 일을 한다. boost.context의 make_fcontext/jump_fcontext로 진짜 stack을 만들어 그 위에서 동기 코드를 돌린다. blocking call에서 fiber를 yield하고 다른 fiber로 jump한다.
#핵심 API
#include <folly/fibers/FiberManager.h>#include <folly/fibers/EventBaseLoopController.h>#include <folly/io/async/EventBase.h>
folly::EventBase evb;folly::fibers::FiberManager& fm = folly::fibers::getFiberManager(evb);
fm.addTask([] { // 이 lambda는 fiber stack에서 실행됨 Result r = doSyncWork(); // blocking call OK saveResult(r);});
evb.loop(); // FiberManager 가 EventBase에 schedule됨fm.addTask(fn)은 fn을 새 fiber stack에서 실행한다. fiber 안의 코드는 baton.wait(), await(future), channel read 등에서 yield할 수 있다.
#await — Future를 fiber 안에서 동기적으로
fm.addTask([] { folly::SemiFuture<int> sf = computeAsync(); int v = folly::fibers::await([&](folly::Promise<int> p) { std::move(sf).via(...).thenValue([p = std::move(p)](int x) mutable { p.setValue(x); }); }); // v를 동기 코드처럼 사용});좀 더 간단한 변형도 있다.
int v = folly::fibers::await(computeAsyncFuture()); // SemiFuture 직접await은 현재 fiber를 yield시키고 Promise를 caller가 채워줄 때 돌아온다. 다른 fiber는 그 사이 계속 돈다.
#Baton — fiber-aware 동기화
folly::fibers::Baton baton;
fm.addTask([&] { std::cout << "wait\n"; baton.wait(); // fiber yield std::cout << "done\n";});
// 다른 fiber 또는 다른 thread에서baton.post(); // wait중인 fiber를 깨움std::condition_variable과 비슷하지만 thread를 block하지 않고 fiber만 block한다. 같은 thread의 다른 fiber는 계속 진행된다.
#Channel — fiber 간 메시지 통신
folly::fibers::Channel<int, 10> ch; // buffered, capacity 10
fm.addTask([&] { for (int i = 0; i < 100; ++i) { ch.send(i); // 가득 차면 fiber yield } ch.close();});
fm.addTask([&] { while (auto v = ch.receive()) { // 비어 있으면 fiber yield process(*v); }});Go의 channel과 비슷하다. producer/consumer를 fiber 단위로 분리한다.
#내부 — stackful의 구현
// folly/fibers/Fiber.h (요약)class Fiber { void* stack_; // mmap된 stack size_t stackSize_; boost::context::fcontext_t ctx_; // saved context (rsp, rbp, ...) std::function<void()> func_; // ...};
// 전환 시void switchToFiber(Fiber* f) { boost::context::jump_fcontext(&main_ctx_, f->ctx_, 0); // jump 후 함수가 yield하면 여기로 돌아옴}boost::context::jump_fcontext는 register 저장/복구를 어셈블리로 수행한다. context switch는 100ns 정도로 OS thread switch(~1μs)보다 한 자릿수 빠르다.
stack은 기본 64KB(설정 가능)다. 1만 개 fiber면 640MB. M
모델이지만 stack memory가 thread보다 절약되는 정도지 무한은 아니다.#C++20 coroutine과의 비교
C++20 coroutine은 stackless다. compiler가 함수의 local을 heap-allocated frame에 변환한다.
| 항목 | folly::fibers (stackful) | C++20 coroutine (stackless) |
|---|---|---|
| stack | 진짜 stack (mmap) | heap-allocated frame |
| memory | fiber당 64KB+ | 함수당 변수 합 |
| 변환 | 없음 (그냥 함수) | compiler 변환 (co_await) |
| 호출 깊이 | 일반 함수처럼 무제한 | coroutine은 stackless라 nested 어려움 |
| 디버깅 | stack trace 정상 | frame이 흩어져 어려움 |
| 표준 | 비표준 | 표준 (C++20) |
C++20 coroutine은 함수당 heap allocation을 한 번 한다. 메모리는 fiber보다 적게 쓰지만 컴파일러 마법이 들어간다. fiber는 메모리가 더 들지만 코드는 그대로다.
#적합한 사용 사례
Fiber 권장:
- Legacy 동기 코드를 그대로 비동기 실행하고 싶을 때
- nested function call이 깊을 때 (RPC -> validate -> log -> db …)
- 디버깅 가능한 stack trace가 필요할 때
C++20 coroutine 권장:
- 새 코드, 메모리 효율이 중요할 때
- 표준 사용 가능한 환경
folly::coro::Task<T>로 통합 가능
Folly는 두 모델을 모두 지원한다. folly/experimental/coro/에 C++20 coroutine 통합이 있다.
#EventBase와의 통합
folly::EventBase evb;folly::fibers::FiberManager::Options opts;opts.stackSize = 64 * 1024;auto& fm = folly::fibers::getFiberManager(evb, opts);
fm.addTask([&] { // I/O는 EventBase에 schedule되고 // 그 결과를 await으로 동기 스타일로 받음 auto result = folly::fibers::await(asyncFetch()); process(result);});
evb.loopForever();FiberManager는 EventBase에 schedule된 task다. EventBase loop이 돌 때마다 ready fiber를 실행한다.
#코드 리뷰 포인트
- fiber stack size가 적정한가? 기본 64KB. 깊은 호출이면 늘리고, 많이 띄우면 줄인다.
- fiber 안에서 thread blocking 호출을 하지 않는가?
std::this_thread::sleep_for는 fiber만이 아니라 전체 thread를 block한다.folly::fibers::sleep_for사용. - shared state에 동시 접근 시 lock이 있는가? 같은 thread의 다른 fiber라도 yield 지점에서 race가 생긴다.
- C++20 coroutine과 혼용하는가? 가능하지만 진입점이 헷갈린다. 모듈 단위로 통일한다.
#자주 보는 안티패턴
// 1. fiber 안에서 thread blockfm.addTask([] { std::this_thread::sleep_for(std::chrono::seconds(1)); // 잘못 // 같은 thread의 모든 fiber가 멈춤});
// 옳음:fm.addTask([] { folly::fibers::Baton b; b.try_wait_for(std::chrono::seconds(1)); // fiber만 yield});
// 2. 너무 큰 stackopts.stackSize = 16 * 1024 * 1024; // 16MBfm.addTask(...); // 1만 개면 160GB
// 3. fiber 외부에서 awaitfolly::fibers::await(sf); // fiber 안에서만 호출 가능 — assert 위반
// 4. shared mutable state without lockint counter = 0;fm.addTask([&] { ... counter++; ... }); // yield 지점에서 race#정리
folly::fibers는 boost.context 기반 stackful coroutine으로 동기 스타일 비동기 코드를 가능하게 한다.await,Baton,Channel이 핵심 동기화 primitive다.- context switch가 ~100ns로 thread보다 빠르지만 stack memory(기본 64KB)를 쓴다.
- C++20 coroutine은 stackless라 메모리 효율적이지만 컴파일러 변환과 디버깅 부담이 있다.
- 새 코드는
folly::coro::Task(C++20 coroutine) 검토 후 결정한다. - fiber 안에서 thread-blocking 호출 금지. fiber-aware variant를 쓴다.
#다음 편
Part 3에서 Executor를 본다. Part 3-01: InlineExecutor에서 시작한다.
#관련 항목
Folly Code Review · 13 of 89
- 1 Folly Code Review — Meta의 production-grade C++ 라이브러리 코드 분석
- 2 Folly 개요 — Meta가 production에서 검증한 utility 모음 분석
- 3 Folly vs Abseil 철학 비교 — performance-first vs std-compatible
- 4 Folly 빌드와 fbcode 환경 — monorepo의 그림자
- 5 Folly API stability 정책 — 어떤 보장도 없다는 솔직함
- 6 Folly production validation 문화 — peta-scale에서 단련된 코드
- 7 folly::Future 분석 — std::future의 한계를 넘는 composable async
- 8 folly::Promise·makeFuture — Future를 만드는 두 길
- 9 folly::SemiFuture vs Future — executor binding의 명시화
- 10 folly::Future thenValue·thenError·thenTry — continuation 체인 분석
- 11 folly::collect·collectAll·collectAny — fan-in 패턴 분석
- 12 folly::Future retry·window·via — 제어 흐름 조합자
- 13 folly::fibers 분석 — M:N stackful coroutine
- 14 folly::InlineExecutor — 호출자 thread에서 즉시 실행
- 15 folly::CPUThreadPoolExecutor — CPU-bound 작업의 표준 thread pool
- 16 folly::IOThreadPoolExecutor — libevent 기반 I/O pool
- 17 folly::ManualExecutor — 결정적 테스트를 위한 수동 진행
- 18 folly::EventBase 분석 — libevent 이벤트 루프의 핵심
- 19 folly::IOBuf 분석 — zero-copy buffer chain의 기본 단위
- 20 folly::IOBufQueue — chain의 push/pull 추상화
- 21 folly::io::Cursor·RWCursor — chain 위의 stream
- 22 folly Zero-copy 패턴 — IOBuf로 ScatterGather I/O 표현
- 23 folly::IOBuf shared semantics — clone·unshare·takeOwnership
- 24 folly::FBString 분석 — SSO + COW 구현
- 25 folly의 fmt::format 통합 — 모던 포맷팅 채택
- 26 folly::StringPiece — string_view 호환 분석
- 27 folly Join·Split utilities — 문자열 분해와 결합
- 28 folly::to·tryTo — text↔num 변환 분석
- 29 folly Conv Customization — 사용자 타입 지원
- 30 folly Conv 성능 비교 — sprintf·stringstream 대비
- 31 folly::F14ValueMap vs std::unordered_map
- 32 folly::F14NodeMap — stable pointer가 필요할 때
- 33 folly::F14VectorMap — cache-friendly iteration
- 34 folly::F14FastMap — auto-select 동작
- 35 folly F14 internals — SIMD probing 메커니즘
- 36 folly::small_vector — inline storage 분석
- 37 folly::FixedString — compile-time string
- 38 folly::AtomicHashMap — lock-free read 분석
- 39 folly::ConcurrentHashMap — sharded 동시 해시 맵
- 40 folly::EvictingCacheMap — LRU 구현 분석
- 41 folly::Synchronized — lock wrapper 패턴
- 42 folly::SharedMutex 분석
- 43 folly::Baton — one-shot wait 동기화
- 44 folly::RWSpinLock 분석
- 45 folly::PicoSpinLock — 1-byte spinlock
- 46 folly::ProducerConsumerQueue — SPSC 큐 분석
- 47 folly::MPMCQueue — multi-producer multi-consumer
- 48 folly::UnboundedQueue — 동적 크기 lock-free
- 49 folly::fibers::Channel — Go-like channel
- 50 folly::dynamic — JSON-like dynamic type 분석
- 51 folly JSON conversion — toJson·parseJson
- 52 folly dynamic ↔ struct — manual marshaling
- 53 folly dynamic Visitor pattern — type별 분기
- 54 folly::Singleton vs Meyers/static — 왜 Folly의 Singleton인가
- 55 folly::SingletonVault 분석 — 등록·소멸·의존성
- 56 folly::Singleton try_get·try_get_fast — TLS-cached 접근
- 57 folly::ExceptionWrapper — type-erased exception holder
- 58 folly::ScopeGuard·SCOPE_EXIT — RAII cleanup
- 59 folly::Optional vs std::optional
- 60 folly::Function vs std::function
- 61 folly::Lazy — 지연 초기화 wrapper
- 62 folly Meta 스타일 code review 패턴
- 63 folly anti-patterns — 잘못 쓰면 std보다 느림
- 64 folly vs std 선택 기준 분석
- 65 folly::coro 개요 — production C++20 코루틴 어댑터
- 66 folly::coro::Task — lazy single-shot 코루틴
- 67 folly::coro::AsyncGenerator — 비동기 스트림
- 68 folly coro blockingWait·collectAll — 동기 경계와 fan-in
- 69 folly::coro::Baton·Mutex — 코루틴-aware 동기화
- 70 folly::Expected — 결과 또는 오류
- 71 folly::Try — Future 결과 wrapper
- 72 folly::Try vs Expected 선택 기준
- 73 folly::Range — 일반 iterator pair
- 74 folly::Uri — URL 파서
- 75 folly Fingerprint64·128 — 분산 hash
- 76 folly SpookyHashV2 — fast non-crypto hash
- 77 folly::Init — main() 부트스트랩
- 78 folly::Indestructible — global lifetime 패턴
- 79 folly::MicroLock — 1-byte 락
- 80 folly::MicroSpinLock — 가장 좁은 spin lock
- 81 folly::format — legacy formatter 분석
- 82 folly::demangle — typeid 디망글링
- 83 folly::DynamicConverter — dynamic ↔ struct
- 84 folly::RecordIO — append-only 로그 파일 포맷
- 85 folly::io::Compression — zstd·lz4·snappy wrapper
- 86 folly::AsyncIO — io_uring·Linux AIO
- 87 folly::CancellationToken — 코루틴·Future 취소 전파
- 88 folly::observer — hot config의 atomic refresh
- 89 fbcode 패턴 모음 — folly 사용의 실전
관련 글
folly::fibers::Channel — Go-like channel
Part 10-04: fibers::Channel — fiber 간 producer/consumer 채널. Go의 channel과 비슷한 sync 점.
같은 시리즈에서 이어 읽기
folly::coro::Task — lazy single-shot 코루틴
Task<T>의 lazy start, executor 바인딩, scheduleOn, 값/예외 전파 — production async의 기본 단위.
같은 시리즈에서 이어 읽기
folly::coro 개요 — production C++20 코루틴 어댑터
folly::coro의 위치 — std 코루틴 위에 Task/AsyncGenerator/Mutex를 쌓아 production async를 가능하게 한 이유.
같은 시리즈에서 이어 읽기