priorityworkerpool

README

Priority Worker Pool

A worker pool in GoLang which schedules job according to priority.

Installation

go get github.com/kc596/priorityworkerpool

Quickstart

import "github.com/kc596/priorityworkerpool"

const (
	poolName   = "testPool"
	numWorkers = 1000
)

var panicHandler = func(alias string, err interface{}) {
	fmt.Println(alias, err) // or use logger
}

pool := priorityworkerpool.New(poolName, numWorkers, panicHandler)

job := func() {
	// code to execute
}

pool.Submit(job, 1+rand.Float64())

APIs

Method	Return Type	Description
New(name string, workers int, panicHandler func(alias string, err interface{})	*Pool	Returns a new worker pool
Submit(job func(), priority float64)	void	Submit a new job to worker pool
WaitGroup()	*sync.WaitGroup	Returns waitgroup to wait for all jobs submitted to finish
ShutDown()	void	Delete queue and prevents pickup of next job from the queue

Documentation

Index

• type Pool
  • func New(name string, workers int, panicHandler func(alias string, err interface{})) *Pool
  • func (pool *Pool) ShutDown()
  • func (pool *Pool) Submit(job func(), priority float64)
  • func (pool *Pool) WaitGroup() *sync.WaitGroup

Types

type Pool

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

Pool is type for Worker Pool

func New

func New(name string, workers int, panicHandler func(alias string, err interface{})) *Pool

New creates a new worker pool to manage goroutines

func (*Pool) ShutDown

func (pool *Pool) ShutDown()

ShutDown prevents pickup of next job from the queue For stopping the already picked up work, use context

func (*Pool) Submit

func (pool *Pool) Submit(job func(), priority float64)

Submit a job to worker pool

func (*Pool) WaitGroup

func (pool *Pool) WaitGroup() *sync.WaitGroup

WaitGroup to wait for all jobs submitted to finish WARNING: would not wait if there are no jobs at the instant