Package fantask provides concurrent tasks control through a shared execution context.

func CancelWithSignal(tasks *Tasks, sigs ...os.Signal)

CancelWithSignal cancels the tasks execution context when any of the given signals is received. If no signals provided, all signals will be handled.

func IgnoreCanceled(err error) error

IgnoreCanceled returns nil on context.Canceled error. Errors are returned unmodified otherwise.

Task is a task interface.

type Task interface {
    Run(ctx context.Context) error
}

TaskFunc is a task function satisfying the fantask.Task interface.

type TaskFunc func(ctx context.Context) error

func (t TaskFunc) Run(ctx context.Context) error

Run executes the task function.

Tasks is a tasks controller.

type Tasks struct {
    // contains filtered or unexported fields
}

func New(tasks ...Task) *Tasks

New creates a new tasks controller instance.

func (t *Tasks) Append(tasks ...Task) *Tasks

Append appends new tasks to the controller tasks list.

func (t *Tasks) Cancel()

Cancel cancels the tasks execution context.

func (t *Tasks) Run(ctx context.Context) error

Run executes all tasks concurrently, waiting for termination.

batou.dev/fantask