workerpool

package

v0.0.2 Latest Latest Go to latest Published: Oct 12, 2022 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var WorkerCount = runtime.NumCPU()

This section is empty.

type Action func(task *Task) error

type SimpleAction func() error

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

func NewSimple(n int) *SimplePool

func (s *SimplePool) Run(f SimpleAction)

func (s *SimplePool) Wait() error

type Task struct {
	Message string
	Value   interface{}

	Action Action

	Tracker *progress.Tracker
	// contains filtered or unexported fields
}

func (t *Task) SetMessage(msg string, args ...interface{})

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

func New(name string, tasks []*Task, action Action) *Workerpool

func (wp *Workerpool) Run() error

func (wp *Workerpool) SerialRun() error

func (wp *Workerpool) SetProgressBuilder(f func(tasks []*Task) progress.Writer)