concurrency

Documentation

Overview

*****************************************************************************

*
*  Description :
*    A very basic and naive implementation of thread pool.
*
****************************************************************************

Index

• type GoRoutinePool
  • func NewGoRoutinePool(numWorkers int) *GoRoutinePool
  • func (p *GoRoutinePool) Schedule(task Task)
  • func (p *GoRoutinePool) Stop()
• type Task

Types

type GoRoutinePool

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

func NewGoRoutinePool

func NewGoRoutinePool(numWorkers int) *GoRoutinePool

NewGoRoutinePool allocates a new thread pool with `numWorkers` goroutines.

func (*GoRoutinePool) Schedule

func (p *GoRoutinePool) Schedule(task Task)

Schedule enqueus a closure to run on the GoRoutinePool's goroutines.

func (*GoRoutinePool) Stop

func (p *GoRoutinePool) Stop()

Stop sends a stop signal to all running goroutines.

type Task

type Task func()

Task represents a work task to be run on the specified thread pool.