concurrency

Documentation

Index

• type BatchTask
  • func NewBatchTask(size int) *BatchTask
  • func (bt *BatchTask) DispatchTask() *Task
  • func (bt *BatchTask) WaitForFinish() []interface{}
• type Task
  • func (t *Task) Answer(reply interface{})
  • func (t *Task) AnswerWithID(id string, reply interface{})
• type TaskResult

Types

type BatchTask

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

func NewBatchTask

func NewBatchTask(size int) *BatchTask

func (*BatchTask) DispatchTask

func (bt *BatchTask) DispatchTask() *Task

func (*BatchTask) WaitForFinish

func (bt *BatchTask) WaitForFinish() []interface{}

type Task

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

func (*Task) Answer

func (t *Task) Answer(reply interface{})

func (*Task) AnswerWithID

func (t *Task) AnswerWithID(id string, reply interface{})

type TaskResult

type TaskResult struct {
	ID     string
	Result interface{}
}