pool

Documentation

Index

• type Config
  • func New(concurrency, buffer int) *Config
  • func (c *Config) Add(f func()) bool
  • func (c *Config) Start() Pool
  • func (c *Config) Stop()
• type Pool

Types

type Config

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

Config holds the configuration for an async implementation of a Pool with configurable concurrency and channel buffer.

func New

func New(concurrency, buffer int) *Config

New returns a new pool.Config ready to be started and added to concurrency sets the number of workers, buffer sets the maximum backlog before pushing to the queue would block

func (*Config) Add

func (c *Config) Add(f func()) bool

Add pushes a function to the pool for processing

func (*Config) Start

func (c *Config) Start() Pool

Start kicks off the worker pool

func (*Config) Stop

func (c *Config) Stop()

Stop closes the pool and drains it

type Pool

type Pool interface {
	Add(func()) bool
	Start() Pool
	Stop()
}

Pool implements a generic worker queue to which arbitrary functions can be pushed to for asynchronous processing