group

type Group ¶

type Group struct {
	// contains filtered or unexported fields
}

Group 收集多个 Actor（函数对）并并发执行。 当任意一个 Actor 返回时，所有其他 Actor 通过 interrupt 函数被中断。 零值可用。

典型用法：用于管理多个长期运行的 goroutine（HTTP server、gRPC server、信号监听等）， 确保其中一个退出时，其他全部被通知停止。

g := &group.Group{}
g.Add(func() error { return httpServer.ListenAndServe() }, func(error) { httpServer.Close() })
g.Add(func() error { return grpcServer.Serve() }, func(error) { grpcServer.GracefulStop() })
g.Add(func() error { <-ctx.Done(); return nil }, func(error) {})
err := g.Run()

func (g *Group) Add(execute func() error, interrupt func(error))

func (g *Group) Run() error

type RunOption ¶

type RunOption func(opts *runOptions)

RunOption 配置 WaitGroupWrapper 的可选参数。

func WithTimeout(timeout time.Duration) RunOption

type WaitGroupWrapper ¶

type WaitGroupWrapper struct {
	// contains filtered or unexported fields
}

WaitGroupWrapper 是 context 感知的 WaitGroup 封装。

特性：

• 每个 goroutine 携带 context（支持超时/取消）
• panic 自动恢复并转换为 error（不会把 panic 当成成功）
• 第一个 error 自动取消 context（级联取消兄弟 goroutine）
• Wait() 返回第一个 error

用法：

wg := group.NewWaitGroup(ctx)
wg.Wrap(func(ctx context.Context) error { return doWork(ctx) })
wg.Wrap(func(ctx context.Context) error { return doMore(ctx) })
if err := wg.Wait(); err != nil { ... }

func NewWaitGroup(ctx context.Context, opts ...RunOption) *WaitGroupWrapper

func (w *WaitGroupWrapper) Wait() error

func (w *WaitGroupWrapper) Wrap(cb func(ctx context.Context) error)