GoSafe runs the given fn using another goroutine, recovers if fn panics.

GoSafeCtx runs the given fn using another goroutine, recovers if fn panics with ctx.

NewRoutineGroup returns a RoutineGroup.

NewStableRunner returns a new StableRunner with given message processor fn.

NewTaskRunner returns a TaskRunner.

NewWorkerGroup returns a WorkerGroup with given job and workers.

RoutineId is only for debug, never use it in production.

RunSafe runs the given fn, recovers if fn panics.

RunSafeCtx runs the given fn, recovers if fn panics with ctx.

ErrTaskRunnerBusy is the error that indicates the runner is busy.

A RoutineGroup is used to group goroutines together and all wait all goroutines to be done.

StableRunner is a runner that guarantees messages are taken out with the pushed order.

A TaskRunner is used to control the concurrency of goroutines.

A WorkerGroup is used to run given number of workers to process jobs.