waitgroup

Documentation

Index

• type Wrapper
  • func (w *Wrapper) Add(delta int)
  • func (w *Wrapper) Count() int
  • func (w *Wrapper) Done()
  • func (w *Wrapper) RecoverableWrap(cb func())
  • func (w *Wrapper) Wrap(cb func())

Types

type Wrapper

type Wrapper struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

Wrapper a wait group wrapper with counter

func (*Wrapper) Add

func (w *Wrapper) Add(delta int)

Add adds delta, which may be negative, to the WaitGroup counter. If the counter becomes zero, all goroutines blocked on Wait are released. If the counter goes negative, Add panics.

func (*Wrapper) Count

func (w *Wrapper) Count() int

Count returns current numbers of goroutines

func (*Wrapper) Done

func (w *Wrapper) Done()

Done decrements the WaitGroup counter by one.

func (*Wrapper) RecoverableWrap

func (w *Wrapper) RecoverableWrap(cb func())

RecoverableWrap recoverable wrap

func (*Wrapper) Wrap

func (w *Wrapper) Wrap(cb func())

Wrap wraps a callback, automatically adding and decreasing delta in the beginning and ending of callback execution respectively.