pool

Documentation

Index

• type Job
• type ThreadPool
  • func NewThreadPool(numWorkers, numMaxQueues int) *ThreadPool
  • func (tp *ThreadPool) AddJob(job Job)
  • func (tp *ThreadPool) GetResults() <-chan int
  • func (tp *ThreadPool) Start()
  • func (tp *ThreadPool) Wait()

Types

type Job

type Job struct {
	ID  int
	Msg string
}

type ThreadPool

type ThreadPool struct {
	NumWorkers   int
	NumMaxQueues int
	// contains filtered or unexported fields
}

func NewThreadPool

func NewThreadPool(numWorkers, numMaxQueues int) *ThreadPool

func (*ThreadPool) AddJob

func (tp *ThreadPool) AddJob(job Job)

func (*ThreadPool) GetResults

func (tp *ThreadPool) GetResults() <-chan int

func (*ThreadPool) Start

func (tp *ThreadPool) Start()

func (*ThreadPool) Wait

func (tp *ThreadPool) Wait()