sync

Documentation

Index

• type LimitWaitGroup
  • func NewLimitWaitGroup(concurrency int) *LimitWaitGroup
  • func (wg *LimitWaitGroup) Add(delta int)
  • func (wg *LimitWaitGroup) AddCheck(delta int) error
  • func (wg *LimitWaitGroup) AddTimeout(timeout time.Duration) bool
  • func (wg *LimitWaitGroup) Done()
  • func (wg *LimitWaitGroup) SetError(err error)
  • func (wg *LimitWaitGroup) Wait()
  • func (wg *LimitWaitGroup) WaitTimeout(timeout time.Duration) bool
• type WaitGroup
  • func NewWaitGroup() *WaitGroup
  • func (wg *WaitGroup) WaitTimeout(timeout time.Duration) bool

Types

type LimitWaitGroup

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

func NewLimitWaitGroup

func NewLimitWaitGroup(concurrency int) *LimitWaitGroup

func (*LimitWaitGroup) Add

func (wg *LimitWaitGroup) Add(delta int)

func (*LimitWaitGroup) AddCheck

func (wg *LimitWaitGroup) AddCheck(delta int) error

AddCheck 检查执行过程中是否出错，出错直接返回

func (*LimitWaitGroup) AddTimeout

func (wg *LimitWaitGroup) AddTimeout(timeout time.Duration) bool

func (*LimitWaitGroup) Done

func (wg *LimitWaitGroup) Done()

func (*LimitWaitGroup) SetError

func (wg *LimitWaitGroup) SetError(err error)

SetError 设置出错信息

func (*LimitWaitGroup) Wait

func (wg *LimitWaitGroup) Wait()

func (*LimitWaitGroup) WaitTimeout

func (wg *LimitWaitGroup) WaitTimeout(timeout time.Duration) bool

type WaitGroup

type WaitGroup struct {
	sync.WaitGroup
}

WaitGroup 增强版 sync.WaitGroup 支持 WaitTimeout

func NewWaitGroup

func NewWaitGroup() *WaitGroup

func (*WaitGroup) WaitTimeout

func (wg *WaitGroup) WaitTimeout(timeout time.Duration) bool

WaitTimeout 支持超时 wait