async

Documentation

Index

• Variables
• type Executor
  • func NewExec[R any](maxWorkerNum int) Executor[R]
• type Result
• type Task

Variables

var DefaultWorkerNum = runtime.GOMAXPROCS(0) * 2

DefaultWorkerNum default number of goroutines is twice the number of GOMAXPROCS

Types

type Executor

type Executor[R any] interface {
	AddTask(task Task[R])
	Result() <-chan Result[R]
}

Executor interface

func NewExec

func NewExec[R any](maxWorkerNum int) Executor[R]

NewExec ...

type Result

type Result[R any] struct {
	Value R
	Err   error
}

Result ...

type Task

type Task[R any] func() (R, error)

Task task func