task_mgr

Documentation

Index

• type Task
• type TaskMgr
  • func (t *TaskMgr) Destroy()
  • func (t *TaskMgr) Initialise(taskMgrName string, goroutineCount uint64, taskQueueBlocking bool, ...)
  • func (t *TaskMgr) PopTask() (Task, error)
  • func (t *TaskMgr) PushTask(task Task) error
  • func (t *TaskMgr) Run(detach bool)
  • func (t *TaskMgr) RunAndWait(detach bool)
  • func (t *TaskMgr) Wait()

Types

type Task

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

type TaskMgr

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

func (*TaskMgr) Destroy

func (t *TaskMgr) Destroy()

func (*TaskMgr) Initialise

func (t *TaskMgr) Initialise(taskMgrName string, goroutineCount uint64, taskQueueBlocking bool, taskQueueMaxSize uint64)

func (*TaskMgr) PopTask

func (t *TaskMgr) PopTask() (Task, error)

func (*TaskMgr) PushTask

func (t *TaskMgr) PushTask(task Task) error

func (*TaskMgr) Run

func (t *TaskMgr) Run(detach bool)

func (*TaskMgr) RunAndWait

func (t *TaskMgr) RunAndWait(detach bool)

func (*TaskMgr) Wait

func (t *TaskMgr) Wait()