tasks

Documentation

Index

• Constants
• func SyncTask(wg *sync.WaitGroup, timeout time.Duration, task TaskAble, ...)
• type ResultType
• type TaskAble
• type TaskResult
  • func ConcurrentTasks(tasks []TaskAble, timeout time.Duration) []TaskResult

Constants

const (
	//ResultFloat64  task flaot64 result
	ResultFloat64 = "float64"
	// ResultInt task int result
	ResultInt = "int"
)

Functions

func SyncTask

func SyncTask(wg *sync.WaitGroup, timeout time.Duration, task TaskAble, outCh chan<- TaskResult)

SyncTask sync exec task

Types

type ResultType

type ResultType string

ResultType task result type

type TaskAble

type TaskAble interface {
	Name() string
	Exec()
	Result() <-chan TaskResult
}

TaskAble can do as a task

type TaskResult

type TaskResult struct {
	Result interface{}
	Type   ResultType
	Error  error
	From   string
}

TaskResult task result

func ConcurrentTasks

func ConcurrentTasks(tasks []TaskAble, timeout time.Duration) []TaskResult

ConcurrentTasks concurrent exec task and block