task

Feb 20, 2024

Changes in this version

+ type Queue struct

+ func NewQueue() *Queue

+ func (q *Queue) Empty() bool

+ func (q *Queue) Pop() interface{}

+ func (q *Queue) Push(x interface{})

+ func (q *Queue) Size() int32

Sep 21, 2022

Changes in this version

+ var ErrTaskNotRunning = errors.New("task not running")

Sep 8, 2022

Changes in this version

type TaskerOption

+ func WithOutput(output io.Writer) TaskerOption

Sep 7, 2022

Changes in this version

+ type Logger interface

+ Printf func(string, ...interface{})

type TaskerOption

+ func WithLogger(l Logger) TaskerOption

Mar 1, 2022

Changes in this version

+ var ErrTaskFulled = errors.New("task fulled")

+ var ErrTaskPanic = errors.New("task panic")

type Tasker

+ func (t *Tasker) GetTaskNum() int

type TaskerOption

+ func WithUniqueId(id int32) TaskerOption

Jan 24, 2022

Changes in this version

+ var ErrTaskFailed = errors.New("task failed")

Jan 17, 2022

Changes in this version

type TaskerOption

+ func WithExecuteTimeout(d time.Duration) TaskerOption

Jan 17, 2022

Changes in this version

+ var TaskDefaultUpdateInterval = time.Second

type TaskerOption

+ func WithUpdateInterval(d time.Duration) TaskerOption

Jul 21, 2021

Changes in this version

+ var TaskDefaultChannelSize = 64

type TaskerOption

+ func WithChannelBufferSize(sz int) TaskerOption

Jun 22, 2021

Changes in this version

type TaskerOption

+ func WithStopFns(f ...StopFn) TaskerOption

Jun 21, 2021

Changes in this version

+ type StopFn func()

type TaskerOption

+ func WithStopFn(f StopFn) TaskerOption

Jun 4, 2021

Changes in this version

type Tasker

+ func (t *Tasker) AddWait(ctx context.Context, f TaskHandler, p ...interface{}) error

May 24, 2021

Changes in this version

type Tasker

+ func (t *Tasker) IsRunning() bool

May 17, 2021

Changes in this version

type TaskerOption

+ func WithStartFns(f ...StartFn) TaskerOption

Apr 15, 2021

Changes in this version

+ type ContextDoneFn func()

+ type StartFn func()

type TaskerOption

+ func WithContextDoneFn(f ContextDoneFn) TaskerOption

+ func WithStartFn(f StartFn) TaskerOption

+ func WithUpdateFn(f UpdateFn) TaskerOption

+ type UpdateFn func()

Apr 13, 2021

Changes in this version

+ var ErrTimeout = errors.New("time out")

+ var TaskDefaultExecuteTimeout = time.Second * 5

+ var TaskDefaultSleep = time.Millisecond * 500

+ var TaskDefaultTimeout = time.Hour * 24 * 30 * 12

+ type ContextDoneCb func()

+ type Task struct

+ type TaskHandler func(context.Context, ...interface{}) error

+ type Tasker struct

+ func NewTasker(max int32) *Tasker

+ func (t *Tasker) Add(ctx context.Context, f TaskHandler, p ...interface{}) error

+ func (t *Tasker) Init(opts ...TaskerOption)

+ func (t *Tasker) ResetTimer()

+ func (t *Tasker) Run(ctx context.Context) error

+ func (t *Tasker) Stop()

+ type TaskerOption func(*TaskerOptions)

+ func WithContextDoneCb(h ContextDoneCb) TaskerOption

+ func WithSleep(d time.Duration) TaskerOption

+ func WithTimeout(d time.Duration) TaskerOption

+ func WithUpdateCb(du UpdateCb) TaskerOption

+ type TaskerOptions struct

+ type UpdateCb func()