pool

Documentation

Overview

* TODO need work with a Queue

Index

• type Pool
  • func New(minRoutines int, maxRoutines int, timeout time.Duration, logger *logr.Logger) *Pool
  • func (p *Pool) Dispatch(task Task) string
  • func (p *Pool) GetResult() *[]TaskStatus
  • func (p *Pool) Shutdown()
• type Task
• type TaskStatus

Types

type Pool

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

Pool work pool

func New

func New(minRoutines int, maxRoutines int, timeout time.Duration, logger *logr.Logger) *Pool

New create new pool

func (*Pool) Dispatch

func (p *Pool) Dispatch(task Task) string

Dispatch submit a task

func (*Pool) GetResult

func (p *Pool) GetResult() *[]TaskStatus

GetResult get tasks result of pool

func (*Pool) Shutdown

func (p *Pool) Shutdown()

Shutdown stutdown pool

type Task

type Task interface {
	GetName() string
	Run(workRoutine int) (interface{}, error)
}

Task task interface

type TaskStatus

type TaskStatus struct {
	Name       string
	ID         string
	Err        error
	Data       interface{}
	Executor   string
	AssignTime time.Time
	StartTime  time.Time
	Duration   time.Duration
}

TaskStatus task status