Documentation
¶
Overview ¶
Package async 提供安全的 goroutine 启动工具。
适用于所有使用此包的后端服务，防止 goroutine panic 导致进程崩溃。
核心特性 ¶
- 自动 recover panic 并记录堆栈
- 支持共享 channel 收集错误（GoSafeWithErrChannel）
- 一行代码替代 go func(){...}()
快速接入 ¶
替代裸 go 关键字：
async.GoSafe(func() {
doSomething()
})
需要收集多个 goroutine 的错误到同一 channel 时：
ch := make(chan error, 10)
async.GoSafeWithErrChannel(ch, func() error {
return doSomething()
})
错误只需日志上报的后台任务：
async.GoSafeWithErr(func() error {
return flushBatch(ctx)
})
携带 context 的安全 goroutine：
async.GoWithContext(ctx, func(ctx context.Context) { doWork(ctx) })
async.GoSafeWithContext(ctx, func(ctx context.Context) error { return doWork(ctx) })
命名后台任务（panic 日志带 task 标签，可按任务聚合告警）：
async.GoSafeLabeled("janitor", func() { sweep() })
async.RunSafeLabeled("batch-flush", func() { flush() })
使用场景 ¶
- 后台任务：日志上报、指标采集、缓存预热
- 并发请求：同时调用多个下游服务
- 异步处理：消息发送、文件处理
Panic 处理 ¶
panic 被 recover 后会：
- 记录 panic 信息和完整堆栈到日志
- GoSafeWithErrChannel 会将 panic 转为 error 发送到共享 channel
- 不会影响主 goroutine 的正常运行
为什么使用标准库 log 而非 logx ¶
本包是使用方的 panic 兜底层，必须保持零内部依赖（依赖叶子节点）。 logx 会间接依赖 middleware、ratelimit 等上层包，而这些包又依赖 async， 若 async 反向依赖 logx 将形成导入环。因此本包刻意使用标准库 log。
Index ¶
- func GoSafe(fn func())
- func GoSafeLabeled(task string, fn func())
- func GoSafeWithContext(ctx context.Context, fn func(ctx context.Context) error)
- func GoSafeWithContextLabeled(ctx context.Context, task string, fn func(ctx context.Context))
- func GoSafeWithErr(fn func() error)
- func GoSafeWithErrChannel(ch chan<- error, fn func() error)
- func GoWithContext(ctx context.Context, fn func(ctx context.Context))
- func ReportPanic(r any)
- func RunSafe(fn func())
- func RunSafeLabeled(task string, fn func())
- func SetPanicHandler(handler PanicHandler)
- type PanicHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GoSafeLabeled ¶ added in v0.5.0
func GoSafeLabeled(task string, fn func())
GoSafeLabeled 与 GoSafe 相同，但 panic 汇报带任务归属标签。 后台循环 / 心跳 / 清扫等命名任务用本变体，运维可直接按 task 聚合。
func GoSafeWithContext ¶
GoSafeWithContext 启动一个携带 ctx 的安全 goroutine，fn 返回的 error （含 panic 转换的 error）经 PanicHandler 记录。等价 GoWithContext + 错误上报。
func GoSafeWithContextLabeled ¶ added in v0.5.0
GoSafeWithContextLabeled 启动带 ctx 的安全 goroutine，panic 汇报带任务归属标签。
func GoSafeWithErr ¶
func GoSafeWithErr(fn func() error)
GoSafeWithErr 启动一个带 panic 恢复的 goroutine 执行 fn。 fn 返回的 error（含 panic 转换的 error）经 PanicHandler 记录后丢弃—— 适合"错误只需日志上报"的后台任务；需要收集错误到共享 channel 用 GoSafeWithErrChannel，需要同步等待/级联取消用 concurrency/group。
func GoSafeWithErrChannel ¶
GoSafeWithErrChannel 启动 fn 并把 panic 与 fn 返回值都发送到共享 channel。
用于需要收集多个 goroutine 的错误到同一 channel 的场景（如 concurrency/group）。 调用方需保证 ch 缓冲足够大（建议至少为参与 goroutine 的数量），避免阻塞。 发送始终非阻塞；若 channel 已满或已被调用方关闭，不阻塞、不崩溃， 相关 panic 经 PanicHandler 输出。调用方应避免在还有 goroutine 未返回时关闭 ch。
func GoWithContext ¶
GoWithContext 启动一个携带 ctx 的安全 goroutine（panic 恢复，无错误上报）。 fn 收到的就是调用方传入的 ctx，取消/超时由调用方管理。
func ReportPanic ¶ added in v0.5.0
func ReportPanic(r any)
ReportPanic 将一次「已被调用方 recover 的 panic」上报给全局 PanicHandler， 供自管 recover 的编排原语（如 syncx.FanInErr 逐槽收编）保持与 GoSafe/RunSafe 统一的观测面——handler 注入方（日志/告警）不漏接任何恢复事件。 msg 形如 "panic recovered: <payload>"；stack 取当前调用栈。
func RunSafe ¶ added in v0.4.0
func RunSafe(fn func())
RunSafe 在当前 goroutine 同步运行 fn，panic 被 recover 并经 PanicHandler 汇报（不重新 panic）。适合"第三方回调不应打死调用方"的场景，如批量执行器 执行用户回调；需要独立 goroutine 用 GoSafe。
func RunSafeLabeled ¶ added in v0.5.0
func RunSafeLabeled(task string, fn func())
RunSafeLabeled 与 RunSafe 相同，但 panic 汇报带任务归属标签。 msg 形如 "task=janitor: boom"，便于按任务维度聚合告警，不依赖堆栈解析。 task 为空时退化为 RunSafe 的消息格式。
func SetPanicHandler ¶
func SetPanicHandler(handler PanicHandler)
SetPanicHandler 设置全局 panic 恢复日志处理器。 应在 main.go 初始化阶段调用，注入 logx 等结构化日志实现。
用法:
async.SetPanicHandler(func(msg string, stack []byte) {
logx.Error("goroutine panic", "error", msg, "stack", string(stack))
})
Types ¶
type PanicHandler ¶
PanicHandler 是 panic 恢复时的日志处理函数。 默认使用标准库 log.Printf。可通过 SetPanicHandler 注入自定义实现（如 logx）。
Source Files