taskpool

Documentation

Index

• Variables
• type FixedNoOrderPool
  • func NewFixedNoOrderPool(size int, bufferSize int) *FixedNoOrderPool
  • func (np *FixedNoOrderPool) Go(f func())
  • func (np *FixedNoOrderPool) GoByIndex(index int, f func())
  • func (np *FixedNoOrderPool) Stop()
• type FixedPool
  • func NewFixedPool(size int, bufferSize int) *FixedPool
  • func (tp *FixedPool) Go(f func())
  • func (tp *FixedPool) GoByIndex(index int, f func())
  • func (tp *FixedPool) Stop()
• type MixedPool
  • func NewMixedPool(nativeSize int, fixedSize int, bufferSize int, v ...interface{}) *MixedPool
  • func (mp *MixedPool) Go(f func())
  • func (mp *MixedPool) GoByIndex(index int, f func())
  • func (mp *MixedPool) Stop()
• type TaskPool
  • func New(size int, maxIdleTime time.Duration) *TaskPool
  • func (tp *TaskPool) Go(f func())
  • func (tp *TaskPool) GoByIndex(index int, f func())
  • func (tp *TaskPool) Stop()

Variables

var (
	// ErrStopped .
	ErrStopped = errors.New("stopped")
)

Types

type FixedNoOrderPool

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

FixedNoOrderPool .

func NewFixedNoOrderPool

func NewFixedNoOrderPool(size int, bufferSize int) *FixedNoOrderPool

NewFixedNoOrderPool .

func (*FixedNoOrderPool) Go

func (np *FixedNoOrderPool) Go(f func())

Go .

func (*FixedNoOrderPool) GoByIndex

func (np *FixedNoOrderPool) GoByIndex(index int, f func())

GoByIndex .

func (*FixedNoOrderPool) Stop

func (np *FixedNoOrderPool) Stop()

Stop .

type FixedPool

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

FixedPool .

func NewFixedPool

func NewFixedPool(size int, bufferSize int) *FixedPool

NewFixedPool .

func (*FixedPool) Go

func (tp *FixedPool) Go(f func())

Go .

func (*FixedPool) GoByIndex

func (tp *FixedPool) GoByIndex(index int, f func())

GoByIndex .

func (*FixedPool) Stop

func (tp *FixedPool) Stop()

Stop .

type MixedPool

type MixedPool struct {
	*FixedNoOrderPool
	// contains filtered or unexported fields
}

MixedPool .

func NewMixedPool

func NewMixedPool(nativeSize int, fixedSize int, bufferSize int, v ...interface{}) *MixedPool

NewMixedPool .

func (*MixedPool) Go

func (mp *MixedPool) Go(f func())

Go .

func (*MixedPool) GoByIndex

func (mp *MixedPool) GoByIndex(index int, f func())

GoByIndex .

func (*MixedPool) Stop

func (mp *MixedPool) Stop()

Stop .

type TaskPool

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

TaskPool .

func New

func New(size int, maxIdleTime time.Duration) *TaskPool

New .

func (*TaskPool) Go

func (tp *TaskPool) Go(f func())

Go .

func (*TaskPool) GoByIndex

func (tp *TaskPool) GoByIndex(index int, f func())

GoByIndex .

func (*TaskPool) Stop

func (tp *TaskPool) Stop()

Stop .