kubernetes/vendor/github.com/modern-go/concurrent/unbounded_executor.go

var HandlePanic …

type UnboundedExecutor …

var GlobalUnboundedExecutor …

// NewUnboundedExecutor creates a new UnboundedExecutor,
// UnboundedExecutor can not be created by &UnboundedExecutor{}
// HandlePanic can be set with a callback to override global HandlePanic
func NewUnboundedExecutor() *UnboundedExecutor { … }

// Go starts a new goroutine and tracks its lifecycle.
// Panic will be recovered and logged automatically, except for StopSignal
func (executor *UnboundedExecutor) Go(handler func(ctx context.Context)) { … }

// Stop cancel all goroutines started by this executor without wait
func (executor *UnboundedExecutor) Stop() { … }

// StopAndWaitForever cancel all goroutines started by this executor and
// wait until all goroutines exited
func (executor *UnboundedExecutor) StopAndWaitForever() { … }

// StopAndWait cancel all goroutines started by this executor and wait.
// Wait can be cancelled by the context passed in.
func (executor *UnboundedExecutor) StopAndWait(ctx context.Context) { … }

func (executor *UnboundedExecutor) checkNoActiveGoroutines() bool { … }