workers

Documentation

Index

• type Task
  • func (t *Task) Process()
• type WorkerPool
  • func (wp *WorkerPool) Run()

Types

type Task

type Task struct {
	ExecFunc func()
	ID       int
}

func (*Task) Process

func (t *Task) Process()

type WorkerPool

type WorkerPool struct {
	Tasks []Task

	Concurrency int
	// contains filtered or unexported fields
}

func (*WorkerPool) Run

func (wp *WorkerPool) Run()