본문으로 건너뛰기
Folly Code Review · 12/89

folly::fibers 분석 — M:N stackful coroutine

· Hawk · 4분 읽기

한 줄 요약: 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의 구현

Fiber cooperative swap

// 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_fcontextregister 저장/복구를 어셈블리로 수행한다. 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
memoryfiber당 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();

FiberManagerEventBase에 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 block
fm.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. 너무 큰 stack
opts.stackSize = 16 * 1024 * 1024; // 16MB
fm.addTask(...); // 1만 개면 160GB
// 3. fiber 외부에서 await
folly::fibers::await(sf); // fiber 안에서만 호출 가능 — assert 위반
// 4. shared mutable state without lock
int 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. 1 Folly Code Review — Meta의 production-grade C++ 라이브러리 코드 분석
  2. 2 Folly 개요 — Meta가 production에서 검증한 utility 모음 분석
  3. 3 Folly vs Abseil 철학 비교 — performance-first vs std-compatible
  4. 4 Folly 빌드와 fbcode 환경 — monorepo의 그림자
  5. 5 Folly API stability 정책 — 어떤 보장도 없다는 솔직함
  6. 6 Folly production validation 문화 — peta-scale에서 단련된 코드
  7. 7 folly::Future 분석 — std::future의 한계를 넘는 composable async
  8. 8 folly::Promise·makeFuture — Future를 만드는 두 길
  9. 9 folly::SemiFuture vs Future — executor binding의 명시화
  10. 10 folly::Future thenValue·thenError·thenTry — continuation 체인 분석
  11. 11 folly::collect·collectAll·collectAny — fan-in 패턴 분석
  12. 12 folly::Future retry·window·via — 제어 흐름 조합자
  13. 13 folly::fibers 분석 — M:N stackful coroutine
  14. 14 folly::InlineExecutor — 호출자 thread에서 즉시 실행
  15. 15 folly::CPUThreadPoolExecutor — CPU-bound 작업의 표준 thread pool
  16. 16 folly::IOThreadPoolExecutor — libevent 기반 I/O pool
  17. 17 folly::ManualExecutor — 결정적 테스트를 위한 수동 진행
  18. 18 folly::EventBase 분석 — libevent 이벤트 루프의 핵심
  19. 19 folly::IOBuf 분석 — zero-copy buffer chain의 기본 단위
  20. 20 folly::IOBufQueue — chain의 push/pull 추상화
  21. 21 folly::io::Cursor·RWCursor — chain 위의 stream
  22. 22 folly Zero-copy 패턴 — IOBuf로 ScatterGather I/O 표현
  23. 23 folly::IOBuf shared semantics — clone·unshare·takeOwnership
  24. 24 folly::FBString 분석 — SSO + COW 구현
  25. 25 folly의 fmt::format 통합 — 모던 포맷팅 채택
  26. 26 folly::StringPiece — string_view 호환 분석
  27. 27 folly Join·Split utilities — 문자열 분해와 결합
  28. 28 folly::to·tryTo — text↔num 변환 분석
  29. 29 folly Conv Customization — 사용자 타입 지원
  30. 30 folly Conv 성능 비교 — sprintf·stringstream 대비
  31. 31 folly::F14ValueMap vs std::unordered_map
  32. 32 folly::F14NodeMap — stable pointer가 필요할 때
  33. 33 folly::F14VectorMap — cache-friendly iteration
  34. 34 folly::F14FastMap — auto-select 동작
  35. 35 folly F14 internals — SIMD probing 메커니즘
  36. 36 folly::small_vector — inline storage 분석
  37. 37 folly::FixedString — compile-time string
  38. 38 folly::AtomicHashMap — lock-free read 분석
  39. 39 folly::ConcurrentHashMap — sharded 동시 해시 맵
  40. 40 folly::EvictingCacheMap — LRU 구현 분석
  41. 41 folly::Synchronized — lock wrapper 패턴
  42. 42 folly::SharedMutex 분석
  43. 43 folly::Baton — one-shot wait 동기화
  44. 44 folly::RWSpinLock 분석
  45. 45 folly::PicoSpinLock — 1-byte spinlock
  46. 46 folly::ProducerConsumerQueue — SPSC 큐 분석
  47. 47 folly::MPMCQueue — multi-producer multi-consumer
  48. 48 folly::UnboundedQueue — 동적 크기 lock-free
  49. 49 folly::fibers::Channel — Go-like channel
  50. 50 folly::dynamic — JSON-like dynamic type 분석
  51. 51 folly JSON conversion — toJson·parseJson
  52. 52 folly dynamic ↔ struct — manual marshaling
  53. 53 folly dynamic Visitor pattern — type별 분기
  54. 54 folly::Singleton vs Meyers/static — 왜 Folly의 Singleton인가
  55. 55 folly::SingletonVault 분석 — 등록·소멸·의존성
  56. 56 folly::Singleton try_get·try_get_fast — TLS-cached 접근
  57. 57 folly::ExceptionWrapper — type-erased exception holder
  58. 58 folly::ScopeGuard·SCOPE_EXIT — RAII cleanup
  59. 59 folly::Optional vs std::optional
  60. 60 folly::Function vs std::function
  61. 61 folly::Lazy — 지연 초기화 wrapper
  62. 62 folly Meta 스타일 code review 패턴
  63. 63 folly anti-patterns — 잘못 쓰면 std보다 느림
  64. 64 folly vs std 선택 기준 분석
  65. 65 folly::coro 개요 — production C++20 코루틴 어댑터
  66. 66 folly::coro::Task — lazy single-shot 코루틴
  67. 67 folly::coro::AsyncGenerator — 비동기 스트림
  68. 68 folly coro blockingWait·collectAll — 동기 경계와 fan-in
  69. 69 folly::coro::Baton·Mutex — 코루틴-aware 동기화
  70. 70 folly::Expected — 결과 또는 오류
  71. 71 folly::Try — Future 결과 wrapper
  72. 72 folly::Try vs Expected 선택 기준
  73. 73 folly::Range — 일반 iterator pair
  74. 74 folly::Uri — URL 파서
  75. 75 folly Fingerprint64·128 — 분산 hash
  76. 76 folly SpookyHashV2 — fast non-crypto hash
  77. 77 folly::Init — main() 부트스트랩
  78. 78 folly::Indestructible — global lifetime 패턴
  79. 79 folly::MicroLock — 1-byte 락
  80. 80 folly::MicroSpinLock — 가장 좁은 spin lock
  81. 81 folly::format — legacy formatter 분석
  82. 82 folly::demangle — typeid 디망글링
  83. 83 folly::DynamicConverter — dynamic ↔ struct
  84. 84 folly::RecordIO — append-only 로그 파일 포맷
  85. 85 folly::io::Compression — zstd·lz4·snappy wrapper
  86. 86 folly::AsyncIO — io_uring·Linux AIO
  87. 87 folly::CancellationToken — 코루틴·Future 취소 전파
  88. 88 folly::observer — hot config의 atomic refresh
  89. 89 fbcode 패턴 모음 — folly 사용의 실전