正确做法是用std::jthread+std::stop_token协作取消,C++17用atomic_bool;重试前须销毁socket和ClientContext;按错误码分类处理,指数退避并加jitter;模板封装retry_invoke,避免悬挂引用和类型擦除。

直接用 std::async 加循环重试是错的——它不控制底层任务是否真正取消,重试时旧任务还在跑,资源泄漏、状态冲突、响应错乱全都会发生。
std::future::wait_for 超时后必须协作式取消任务
std::future 本身没有取消能力,wait_for 返回 std::future_status::timeout 只代表“还没返回”,不代表任务停了。继续发起新重试,等于让多个相同请求并行打向服务端。
- 用
std::jthread+std::stop_token(C++20)是最轻量可靠的方案:任务内部定期检查token.stop_requested(),收到信号就清理 socket、释放 buffer、提前退出 - 若仍在 C++17 或更早环境,改用
std::atomic_bool作取消标志,所有 I/O 操作前都加一次if (cancelled.load()) return; - 别在重试逻辑里调用
std::this_thread::sleep_for后直接continue——这会让线程空转,应把 sleep 也放进异步任务里,或用steady_timer::async_wait驱动下一轮
重试判定不能只看异常类型
HTTP 状态码、gRPC 错误码、底层连接错误,三者语义完全不同,混在一起重试会放大故障。
- 对
CURLE_COULDNT_CONNECT、boost::asio::error::connection_refused这类网络层失败,可重试,但需指数退避(如 100ms → 200ms → 400ms) - 对 HTTP 401/403/404 或 gRPC
INVALID_ARGUMENT、NOT_FOUND,重试无意义,应立即失败 - 对 HTTP 503/429 或 gRPC
UNAVAILABLE、RESOURCE_EXHAUSTED,才值得重试;且每次重试前必须销毁旧tcp::socket和grpc::ClientContext实例,否则句柄残留导致后续连接失败
用模板封装重试逻辑,避免重复代码和悬挂引用
把重试写成全局函数或每个 RPC 调用里硬编码,会导致退避策略不统一、日志缺失、取消逻辑遗漏。
立即学习“C++免费学习笔记(深入)”;
- 定义模板函数
retry_invoke,接收可调用对象、最大重试次数、初始延迟、以及判断是否重试的谓词should_retry - 参数必须用
std::forward完美转发,否则右值参数(如临时std::string)会被转成左值,触发深拷贝 - 不要用
std::function包装任务——类型擦除开销大,且容易捕获局部变量引发悬挂;直接传 lambda 或函数指针 - 延迟时间用
std::chrono::milliseconds计算,上限设为 5s,防止第 10 次重试等 51.2 秒;叠加 ±10% 随机 jitter(std::uniform_int_distribution)打散重试时间点
gRPC 异步调用要显式管理 ClientContext 生命周期
gRPC 的 AsyncUnaryCall 或 AsyncClientReaderWriter 不自动绑定 ClientContext 生命周期,重试时若复用 context,会导致 deadline 错乱、metadata 覆盖、cancel 被忽略。
- 每次重试必须新建
std::unique_ptr<grpc::ClientContext>,设置独立set_deadline和AddMetadata - 别在 lambda 中捕获
this指针去调用成员函数——重试跨线程时,对象可能已被析构;改用std::shared_ptr<self>持有强引用 - 异步完成回调中,先检查
status.ok(),再检查context->IsCancelled(),最后才处理响应体;三者顺序错一个,就可能解包已释放内存
最易被忽略的是:重试不是简单地“再跑一遍”,而是要确保上一轮彻底终止、资源完全释放、上下文完全重建——任何环节残留,都会让重试从容错机制变成故障放大器。


















