async

Documentation

Index

• type Task
  • func NewTask(f func() (interface{}, error)) *Task
  • func (t *Task) Run()
• type WorkerPool
  • func NewWorkerPool() *WorkerPool
  • func NewWorkerPoolWithSize(size int) *WorkerPool
  • func (p *WorkerPool) AddTask(taskFunc func() (interface{}, error))
  • func (p *WorkerPool) GetTasks() []*Task
  • func (p *WorkerPool) StopWait()

Types

type Task

type Task struct {
	Err    error
	Result interface{}
	// contains filtered or unexported fields
}

a task wraps a function and its response

func NewTask

func NewTask(f func() (interface{}, error)) *Task

func (*Task) Run

func (t *Task) Run()

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool() *WorkerPool

func NewWorkerPoolWithSize

func NewWorkerPoolWithSize(size int) *WorkerPool

func (*WorkerPool) AddTask

func (p *WorkerPool) AddTask(taskFunc func() (interface{}, error))

func (*WorkerPool) GetTasks

func (p *WorkerPool) GetTasks() []*Task

func (*WorkerPool) StopWait

func (p *WorkerPool) StopWait()