Loading...
Loading...
Compare original and translation side by side
co_awaitco_yieldco_returnpromise_typeco_awaitco_yieldco_returnpromise_type// co_return — return a value and end the coroutine
co_return value;
// co_yield — produce a value, suspend, resume later
co_yield value;
// co_await — suspend until an awaitable completes
auto result = co_await some_awaitable;promise_type// co_return — 返回值并结束协程
co_return value;
// co_yield — 生成值,挂起协程,后续可恢复
co_yield value;
// co_await — 挂起协程直到awaitable完成
auto result = co_await some_awaitable;promise_type#include <coroutine>
#include <stdexcept>
#include <optional>
template <typename T>
struct Task {
struct promise_type {
std::optional<T> value;
std::exception_ptr exception;
Task get_return_object() {
return Task{std::coroutine_handle<promise_type>::from_promise(*this)};
}
std::suspend_always initial_suspend() { return {}; } // lazy start
std::suspend_always final_suspend() noexcept { return {}; }
void return_value(T v) { value = std::move(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(Task&&) = default;
Task& operator=(Task&&) = default;
~Task() { if (handle) handle.destroy(); }
T get() {
handle.resume(); // resume to completion
if (handle.promise().exception)
std::rethrow_exception(handle.promise().exception);
return std::move(*handle.promise().value);
}
};
// Usage
Task<int> compute() {
co_return 42;
}
int main() {
auto task = compute();
int result = task.get(); // 42
}#include <coroutine>
#include <stdexcept>
#include <optional>
template <typename T>
struct Task {
struct promise_type {
std::optional<T> value;
std::exception_ptr exception;
Task get_return_object() {
return Task{std::coroutine_handle<promise_type>::from_promise(*this)};
}
std::suspend_always initial_suspend() { return {}; } // 延迟启动
std::suspend_always final_suspend() noexcept { return {}; }
void return_value(T v) { value = std::move(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(Task&&) = default;
Task& operator=(Task&&) = default;
~Task() { if (handle) handle.destroy(); }
T get() {
handle.resume(); // 恢复协程至完成
if (handle.promise().exception)
std::rethrow_exception(handle.promise().exception);
return std::move(*handle.promise().value);
}
};
// 使用示例
Task<int> compute() {
co_return 42;
}
int main() {
auto task = compute();
int result = task.get(); // 结果为42
}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 {}; }
void return_void() {}
void unhandled_exception() { throw; }
std::suspend_always yield_value(T value) {
current_value = value;
return {}; // suspend after yielding
}
};
std::coroutine_handle<promise_type> handle;
explicit Generator(std::coroutine_handle<promise_type> h) : handle(h) {}
~Generator() { if (handle) handle.destroy(); }
struct iterator {
std::coroutine_handle<promise_type> handle;
bool done;
iterator& operator++() {
handle.resume();
done = handle.done();
return *this;
}
T operator*() const { return handle.promise().current_value; }
bool operator!=(std::default_sentinel_t) const { return !done; }
};
iterator begin() {
handle.resume(); // advance to first yield
return {handle, handle.done()};
}
std::default_sentinel_t end() { return {}; }
};
// Usage
Generator<int> iota(int start, int end) {
for (int i = start; i < end; ++i)
co_yield i;
}
for (int x : iota(0, 5)) {
std::cout << x << ' '; // 0 1 2 3 4
}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 {}; }
void return_void() {}
void unhandled_exception() { throw; }
std::suspend_always yield_value(T value) {
current_value = value;
return {}; // 生成值后挂起
}
};
std::coroutine_handle<promise_type> handle;
explicit Generator(std::coroutine_handle<promise_type> h) : handle(h) {}
~Generator() { if (handle) handle.destroy(); }
struct iterator {
std::coroutine_handle<promise_type> handle;
bool done;
iterator& operator++() {
handle.resume();
done = handle.done();
return *this;
}
T operator*() const { return handle.promise().current_value; }
bool operator!=(std::default_sentinel_t) const { return !done; }
};
iterator begin() {
handle.resume(); // 推进到第一个生成值
return {handle, handle.done()};
}
std::default_sentinel_t end() { return {}; }
};
// 使用示例
Generator<int> iota(int start, int end) {
for (int i = start; i < end; ++i)
co_yield i;
}
for (int x : iota(0, 5)) {
std::cout << x << ' '; // 输出:0 1 2 3 4
}// An awaitable has three methods:
// await_ready() — true means don't suspend
// await_suspend(handle) — suspend: store handle, schedule resume
// await_resume() — return value of co_await expression
struct TimerAwaitable {
int delay_ms;
bool await_ready() const noexcept { return delay_ms <= 0; }
void await_suspend(std::coroutine_handle<> h) {
// Schedule h.resume() to be called after delay
std::thread([h, this]() {
std::this_thread::sleep_for(std::chrono::milliseconds(delay_ms));
h.resume();
}).detach();
}
void await_resume() const noexcept {} // no return value
};
// suspend_always and suspend_never are built-in awaitables
std::suspend_always{}; // always suspends
std::suspend_never{}; // never suspends (no-op)// 一个Awaitable需包含三个方法:
// await_ready() — 返回true表示不挂起
// await_suspend(handle) — 挂起:存储handle,调度恢复
// await_resume() — 返回co_await表达式的结果
struct TimerAwaitable {
int delay_ms;
bool await_ready() const noexcept { return delay_ms <= 0; }
void await_suspend(std::coroutine_handle<> h) {
// 调度h.resume()在延迟后执行
std::thread([h, this]() {
std::this_thread::sleep_for(std::chrono::milliseconds(delay_ms));
h.resume();
}).detach();
}
void await_resume() const noexcept {} // 无返回值
};
// suspend_always和suspend_never是内置Awaitable
std::suspend_always{}; // 始终挂起
std::suspend_never{}; // 从不挂起(空操作)// Inspect frame size with Compiler Explorer (godbolt.org)
// Compile with: g++ -std=c++20 -O2 -S
// Look for: operator new call size in the generated asm
// Or: clang -std=c++20 -O2 -emit-llvm -S | grep "coro.size"
// Reduce frame size:
// 1. Don't keep large objects alive across co_await
struct Bad {
std::vector<char> large_buf; // whole vector lives in frame
co_return large_buf.size(); // large_buf crosses suspension
};
// 2. Move data out before suspending
std::vector<char> buf = get_data();
size_t sz = buf.size(); // capture only what's needed
buf.clear(); // release before suspension
co_await next_event;
// sz still valid; buf released// 使用Compiler Explorer(godbolt.org)检查帧大小
// 编译命令:g++ -std=c++20 -O2 -S
// 在生成的汇编中查找:operator new调用的大小
// 或者:clang -std=c++20 -O2 -emit-llvm -S | grep "coro.size"
// 减小帧大小:
// 1. 不要让大型对象在co_await期间保持存活
struct Bad {
std::vector<char> large_buf; // 整个vector存放在帧中
co_return large_buf.size(); // large_buf跨越挂起点
};
// 2. 在挂起前转移数据
std::vector<char> buf = get_data();
size_t sz = buf.size(); // 仅保留所需数据
buf.clear(); // 挂起前释放内存
co_await next_event;
// sz仍然有效;buf已释放undefinedundefinedundefinedundefined| Issue | Cause | Fix |
|---|---|---|
| Function missing coroutine return type | Change return type to a coroutine type |
Dangling handle after | Using handle after coroutine finishes | Check |
| Double-resume | Resuming an already-resumed coroutine | Track state; only resume when suspended |
| Coroutine frame never freed | Forgot | Use RAII wrapper (Task, Generator) |
| Heap allocation overhead | New frame per coroutine call | Enable HALO (Heap Allocation eLision Optimization) with |
| Recursive co_await depth | Stack overflow from deep chains | Use |
| 问题 | 原因 | 修复方案 |
|---|---|---|
非协程中使用 | 函数缺少协程返回类型 | 将返回类型改为协程类型 |
| 协程结束后仍使用handle | 恢复前检查 |
| 重复恢复 | 恢复已恢复的协程 | 跟踪状态;仅在挂起时恢复 |
| 协程帧从未释放 | 忘记调用 | 使用RAII包装器(Task、Generator) |
| 堆分配开销 | 每次协程调用都会创建新帧 | 使用 |
| 递归co_await深度过深 | 深层调用链导致栈溢出 | 使用 |
skills/compilers/cpp-templatesskills/rust/rust-async-internalsskills/debuggers/gdbskills/compilers/cpp-templatesskills/rust/rust-async-internalsskills/debuggers/gdb