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 chan *resource

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.