workerpool

Documentation

Index

• func Process(workerID int, t *Task)
• type Pool
  • func NewPool(tasks []*Task, concurrency, totalTasks int) *Pool
  • func (p *Pool) Run()
• type Task
  • func NewTask(f func(interface{}) error, data interface{}, ID int) *Task
• type Worker
  • func NewWorker(channel chan *Task, ID int) *Worker
  • func (wr *Worker) Start(wg *sync.WaitGroup)

Functions

func Process

func Process(workerID int, t *Task)

Types

type Pool

type Pool struct {
	Tasks []*Task
	// contains filtered or unexported fields
}

func NewPool

func NewPool(tasks []*Task, concurrency, totalTasks int) *Pool

NewPool creates a new pool

func (*Pool) Run

func (p *Pool) Run()

type Task

type Task struct {
	ID   int
	Err  error
	Data interface{}
	// contains filtered or unexported fields
}

Task source reference https://github.com/Joker666/goworkerpool/blob/main/workerpool/task.go

func NewTask

func NewTask(f func(interface{}) error, data interface{}, ID int) *Task

type Worker

type Worker struct {
	ID int
	// contains filtered or unexported fields
}

Worker source reference https://github.com/Joker666/goworkerpool/blob/main/workerpool/worker.go

func NewWorker

func NewWorker(channel chan *Task, ID int) *Worker

func (*Worker) Start

func (wr *Worker) Start(wg *sync.WaitGroup)