pool

Documentation

Index

• Variables
• type BasePool
  • func NewBasePool() BasePool
  • func (p *BasePool) GenTaskID() uint64
  • func (p *BasePool) LastTunerTs() time.Time
  • func (p *BasePool) Name() string
  • func (p *BasePool) SetLastTuneTs(t time.Time)
  • func (p *BasePool) SetName(name string)

Variables

var (
	// ErrPoolClosed will be returned when submitting task to a closed pool.
	ErrPoolClosed = errors.New("this pool has been closed")

	// ErrPoolOverload will be returned when the pool is full and no workers available.
	ErrPoolOverload = errors.New("the number of concurrency has reached the upper limit and Block is set")

	// ErrPoolParamsInvalid will be returned when the pool params are invalid.
	ErrPoolParamsInvalid = errors.New("the pool params are invalid")
)

Types

type BasePool

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

BasePool is base class of pool

func NewBasePool

func NewBasePool() BasePool

NewBasePool is to create a new BasePool.

func (*BasePool) GenTaskID

func (p *BasePool) GenTaskID() uint64

GenTaskID is to get a new task ID.

func (*BasePool) LastTunerTs

func (p *BasePool) LastTunerTs() time.Time

LastTunerTs returns the last time when the pool was tuned.

func (*BasePool) Name

func (p *BasePool) Name() string

Name is to get name.

func (*BasePool) SetLastTuneTs

func (p *BasePool) SetLastTuneTs(t time.Time)

SetLastTuneTs sets the last time when the pool was tuned.

func (*BasePool) SetName

func (p *BasePool) SetName(name string)

SetName is to set name.