Versions in this module Expand all Collapse all v1 v1.51.8 Jul 13, 2021 v1.51.7 Apr 26, 2021 Changes in this version + func GoSafe(fn func()) + func RoutineId() uint64 + func RunSafe(fn func()) + 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()) + type WorkerGroup struct + func NewWorkerGroup(job func(), workers int) WorkerGroup + func (wg WorkerGroup) Start()
Go to main page