Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

async_task_manager

package

Go to main page

Versions in this module

v1

v1.0.1

Dec 1, 2023

v1.0.0

Nov 22, 2023

Changes in this version

+ type DefaultOneToManyTask struct

+ func NewDefaultOneToManyTask(taskTarget string) *DefaultOneToManyTask

+ func (t *DefaultOneToManyTask) Copy() OneToManyTaskInterface

+ func (t *DefaultOneToManyTask) GetHandleResult() interface{}

+ func (t *DefaultOneToManyTask) GetHandleTag() *TaskTag

+ func (t *DefaultOneToManyTask) SetHandleResult(res interface{})

+ func (t *DefaultOneToManyTask) SetHandleTag(tag *TaskTag)

+ func (t *DefaultOneToManyTask) SetTaskTag(tag *TaskTag)

+ type DefaultOneToManyTaskManager struct

+ func (m *DefaultOneToManyTaskManager) AddAsyncTask(t OneToManyTaskInterface, cb func(res *OneToManyTaskResult), ...) error

+ func (m *DefaultOneToManyTaskManager) CheckTaskInWork(workTag string) (bool, error)

+ func (m *DefaultOneToManyTaskManager) FinishTouch()

+ func (m *DefaultOneToManyTaskManager) GetManagerStatus() uint8

+ func (m *DefaultOneToManyTaskManager) GetWaitLength() int

+ func (m *DefaultOneToManyTaskManager) GetWorkerLength() int

+ func (m *DefaultOneToManyTaskManager) SetWaitListMaxLength(l int)

+ func (m *DefaultOneToManyTaskManager) SetWorkPoolSize(s int)

+ func (m *DefaultOneToManyTaskManager) Start()

+ func (m *DefaultOneToManyTaskManager) Stop()

+ type OneToManyTaskHandleInterface interface

+ GetTarget func() *TaskTag

+ SetHandleCallBack func(f AsyncTaskCallBack)

+ Start func(AsyncTaskInterface)

+ Stop func()

+ type OneToManyTaskInterface interface

+ Copy func() OneToManyTaskInterface

+ GetHandleResult func() interface{}

+ GetHandleTag func() *TaskTag

+ SetHandleResult func(res interface{})

+ SetHandleTag func(tag *TaskTag)

+ SetTaskTag func(tag *TaskTag)

+ type OneToManyTaskManagerInterface interface

+ AddAsyncTask func(t OneToManyTaskInterface, cb func(res *OneToManyTaskResult), ...) error

+ CheckTaskInWork func(tag string) (bool, error)

+ GetManagerStatus func() uint8

+ GetWaitLength func() int

+ GetWorkerLength func() int

+ SetWaitListMaxLength func(l int)

+ SetWorkPoolSize func(s int)

+ Start func()

+ Stop func()

+ type OneToManyTaskResult struct

+ EndTime int64

+ ResultMap map[string]interface{}

+ StartTime int64

+ Status uint8

+ Task OneToManyTaskInterface

v0

v0.0.1

Nov 20, 2023

Changes in this version

+ const DefaultWaitLength

+ const DefaultWorkLength

+ const ManagerError

+ const ManagerFinish

+ const ManagerInit

+ const ManagerStart

+ const ManagerStop

+ const TaskONError

+ const TaskONFinish

+ const TaskONInit

+ const TaskONStart

+ const TaskONStop

+ const TaskSep

+ var UserStopError error

+ func GetUUID() string

+ type AsyncTaskCallBack func(AsyncTaskInterface)

+ type AsyncTaskHandle interface

+ SetHandleCallBack func(f AsyncTaskCallBack)

+ Start func(AsyncTaskInterface)

+ Stop func()

+ type AsyncTaskInterface interface

+ GetEndUnix func() int64

+ GetError func() error

+ GetStartUnix func() int64

+ GetStatus func() uint8

+ GetTag func() *TaskTag

+ SetEndUnix func(end int64)

+ SetError func(e error)

+ SetStartUnix func(end int64)

+ SetStatus func(s uint8)

+ type AsyncTaskManagerInterface interface

+ AddAsyncTask func(t AsyncTaskInterface, h AsyncTaskHandle, cb ...AsyncTaskCallBack) error

+ CheckTaskInWork func(tag string) (bool, error)

+ GetManagerStatus func() uint8

+ GetWaitLength func() int

+ GetWorkerLength func() int

+ SetFinishCallBack func(f func(*TaskManagerResult))

+ SetProgressCallBack func(p int, cb ProgressCallBack)

+ SetTaskMaxLength func(s int)

+ SetWaitListMaxLength func(l int)

+ SetWorkPoolSize func(s int)

+ Start func()

+ Stop func()

+ type DefaultAsyncTask struct

+ End int64

+ Err error

+ Start int64

+ Status uint8

+ Tag *TaskTag

+ func (t *DefaultAsyncTask) GetEndUnix() int64

+ func (t *DefaultAsyncTask) GetError() error

+ func (t *DefaultAsyncTask) GetStartUnix() int64

+ func (t *DefaultAsyncTask) GetStatus() uint8

+ func (t *DefaultAsyncTask) GetTag() *TaskTag

+ func (t *DefaultAsyncTask) SetEndUnix(end int64)

+ func (t *DefaultAsyncTask) SetError(e error)

+ func (t *DefaultAsyncTask) SetStartUnix(start int64)

+ func (t *DefaultAsyncTask) SetStatus(s uint8)

+ type DefaultAsyncTaskManager struct

+ func NewDefaultAsyncTaskManager() *DefaultAsyncTaskManager

+ func (m *DefaultAsyncTaskManager) AddAsyncTask(t AsyncTaskInterface, h AsyncTaskHandle, cbs ...AsyncTaskCallBack) error

+ func (m *DefaultAsyncTaskManager) CheckTaskInWork(workTag string) (bool, error)

+ func (m *DefaultAsyncTaskManager) GetManagerStatus() uint8

+ func (m *DefaultAsyncTaskManager) GetWaitLength() int

+ func (m *DefaultAsyncTaskManager) GetWorkerLength() int

+ func (m *DefaultAsyncTaskManager) SetFinishCallBack(f func(*TaskManagerResult))

+ func (m *DefaultAsyncTaskManager) SetProgressCallBack(p int, cb ProgressCallBack)

+ func (m *DefaultAsyncTaskManager) SetTaskMaxLength(s int)

+ func (m *DefaultAsyncTaskManager) SetWaitListMaxLength(l int)

+ func (m *DefaultAsyncTaskManager) SetWorkPoolSize(s int)

+ func (m *DefaultAsyncTaskManager) Start()

+ func (m *DefaultAsyncTaskManager) Stop()

+ func (m *DefaultAsyncTaskManager) TaskResultCallBack(res AsyncTaskInterface)

+ type ProgressCallBack func(*TaskProgress)

+ type TaskManagerResult struct

+ EndTime int64

+ Length uint64

+ StartTime int64

+ Status uint8

+ TagsMap map[string]AsyncTaskInterface

+ type TaskProgress struct

+ AllTaskNum int

+ ParentTime int64

+ Progress int

+ WorkNum int

+ type TaskTag struct

+ Id string

+ Mark string

+ func NewTaskTag(tag string) *TaskTag

+ func (t *TaskTag) Parse(s string) (err error)

+ func (t *TaskTag) String() string