xsync

Documentation

Index

• type Group
  • func NewGroup(option ...Option) *Group
  • func (g *Group) Go(f func(context.Context) error)
  • func (g *Group) Wait()
• type Option
  • func WithContext(ctx context.Context) Option
  • func WithHandler(handler func(context.Context)) Option
  • func WithMaxGoNum(maxGoNum int64) Option

Types

type Group

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

func NewGroup

func NewGroup(option ...Option) *Group

NewGroup 创建Group

func (*Group) Go

func (g *Group) Go(f func(context.Context) error)

Go 启动协程并捕获异常 异常退出、panic退出

func (*Group) Wait

func (g *Group) Wait()

type Option

type Option func(group *Group)

func WithContext

func WithContext(ctx context.Context) Option

WithContext 上下文

func WithHandler

func WithHandler(handler func(context.Context)) Option

WithHandler 错误处理

func WithMaxGoNum

func WithMaxGoNum(maxGoNum int64) Option

WithMaxGoNum 限流 至少一个goroutine 全局协程管理限流必须带上ctx超时管理，否则会阻塞