async

Documentation

Index

• Variables
• type AsyncResult
• type IAsync
  • func NewAsync[Result any](maxWorkerNum int) IAsync[Result]
• 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[Result any] struct {
	Value Result
	Err   error
}

AsyncResult result struct

type IAsync

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

IAsync interface

func NewAsync

func NewAsync[Result any](maxWorkerNum int) IAsync[Result]

NewAsync ...

type Task

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

Task task func