pooling

Documentation

Overview

Package pooling implements the wayback workers pool.

Index

• Variables
• type Pool
  • func New(size int) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) Roll(service func())

Variables

var (
	ErrPoolNotExist = errors.New("pool not exist")  // ErrPoolNotExist pool not exist
	ErrTimeout      = errors.New("process timeout") // ErrTimeout process timeout
)

Types

type Pool

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

Pool handles a pool of services.

func New

func New(size int) *Pool

New a resource pool of the specified size Resources are created concurrently to save resource initialization time

func (*Pool) Close

func (p *Pool) Close()

Close closes worker pool

func (*Pool) Roll

func (p *Pool) Roll(service func())

Roll wrapper service as function to the resource pool.