Versions in this module Expand all Collapse all v1 v1.1.4 May 27, 2022 v1.1.3 Dec 15, 2021 Changes in this version + var ErrCanceled = context.Canceled + var ErrTimeout = context.DeadlineExceeded + func DoWithTimeout(fn func() error, timeout time.Duration, opts ...FxOption) error + func GoSafe(fn func()) + func Rescue(cleanups ...func()) + func RoutineId() uint64 + func RunSafe(fn func()) + type FxOption func() context.Context + func WithContext(ctx context.Context) FxOption + type RoutineGroup struct + func NewRoutineGroup() *RoutineGroup + func (g *RoutineGroup) Run(fn func()) + func (g *RoutineGroup) RunSafe(fn func()) + func (g *RoutineGroup) Wait() + type TaskRunner struct + func NewTaskRunner(concurrency int) *TaskRunner + func (rp *TaskRunner) Schedule(task func())
Go to main page