waitgroup

func (*WaitGroup) Run ¶

func (w *WaitGroup) Run(exec func())

Run runs a function in a goroutine, adds 1 to WaitGroup and calls done when function returns.

func (*WaitGroup) RunWithLogger ¶

func (w *WaitGroup) RunWithLogger(exec func(), logger *zap.Logger)

func (*WaitGroup) RunWithRecover ¶

func (w *WaitGroup) RunWithRecover(exec func(), recoverFn func(r interface{}), logger *zap.Logger)

RunWithRecover wraps goroutine startup call with force recovery, add 1 to WaitGroup and call done when function return. it will dump current goroutine stack into log if catch any recover result. exec is that execute logic function. recoverFn is that handler will be called after recover and before dump stack, passing `nil` means noop.

func (*WaitGroupPool) Close ¶

func (w *WaitGroupPool) Close()

func (*WaitGroupPool) RunWithRecover ¶

func (w *WaitGroupPool) RunWithRecover(exec func(), recoverFn func(r interface{}), logger *zap.Logger)

RunWithRecover runs a function in a goroutine, adds 1 to WaitGroup and calls done when function returns.