waitgroup

package

v1.4.0-nextgen.202510.2 Latest Latest Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type WaitGroup struct {
	waitgroup.WaitGroup
}

WaitGroup wraps waitgroup.WaitGroup to avoid cycle import. It increases the metrics counter if panic.

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

func (w *WaitGroup) RunWithRecover(exec func(), recoverFn func(r any), logger *zap.Logger)

type WaitGroupPool struct {
	waitgroup.WaitGroupPool
}

func NewWaitGroupPool(n int, idleDuration time.Duration) *WaitGroupPool

func (w *WaitGroupPool) RunWithRecover(exec func(), recoverFn func(r any), logger *zap.Logger)