task

Feb 13, 2024

Changes in this version

type Task

+ func (task *Task) TaskId() int64

+ func (task *Task) WorkId() int64

Dec 21, 2023

Changes in this version

type Lock

+ func (lock *Lock) Locks(cb func())

Oct 12, 2023

Changes in this version

+ type Meta struct

+ FileLine string

+ Prefix string

type Task

+ Meta Meta

Aug 14, 2022

Changes in this version

+ func WaitN(n int, action func(*Task, *Lock) error)

Aug 1, 2022

Changes in this version

+ const POOL

+ const TASK

+ const WORK

+ type Any = interface

type Lock

+ func (lock *Lock) Lock() func()

type Pool

+ Logger func(...Any)

+ func (pool *Pool) WaitN(n int, cb func(*Task, *Lock) error)

type Task

+ Action func(*Task) error

+ Logger func(...Any)

+ Params interface{}

+ func (task *Task) Context() context.Context

type Work

+ Logger func(...Any)

+ func (work *Work) Info() string

Oct 14, 2021

Changes in this version

+ const StatusCancel

+ const StatusFinish

+ const StatusPrepare

+ const StatusProcess

+ func Init(conf *conf.Conf)

+ type Lock struct

+ func (l *Lock) RLock() func()

+ func (l *Lock) WLock() func()

+ type Pool struct

+ Ctx context.Context

+ ID int64

+ func New(conf *conf.Conf) *Pool

+ func Wait(arg []interface{}, cb func(*Task, *Lock) error) *Pool

+ func (pool *Pool) Add(count int) *Pool

+ func (pool *Pool) Close()

+ func (pool *Pool) Put(arg interface{}, cb func(*Task) error) *Task

+ func (pool *Pool) Wait(args []interface{}, cb func(*Task, *Lock) error) *Pool

+ type Task struct

+ Arg interface{}

+ CB func(*Task) error

+ Ctx context.Context

+ Error interface{}

+ FinishTime time.Time

+ ID int64

+ PrepareTime time.Time

+ ProcessTime time.Time

+ Status int

+ func Put(arg interface{}, cb func(*Task) error) *Task

+ func (task *Task) Info() string

+ func (task *Task) Pool() *Pool

+ func (task *Task) Run()

+ type Work struct

+ Ctx context.Context

+ ID int64

+ func (work *Work) Run()