async

Documentation

Index

• Variables
• type AsyncResult
• type IAsync
  • func NewAsync(maxWorkerNum int) IAsync
• type Task

Variables

var DefaultWorkerNum = runtime.GOMAXPROCS(0) * 2

DefaultWorkerNum default number of goroutines is twice the number of GOMAXPROCS

Types

type AsyncResult

type AsyncResult struct {
	Value interface{}
	Err   error
}

AsyncResult result struct

type IAsync

type IAsync interface {
	AddTask(task Task)
	Result() <-chan AsyncResult
}

IAsync interface

func NewAsync

func NewAsync(maxWorkerNum int) IAsync

NewAsync ...

type Task

type Task func() (interface{}, error)

Task task func