gpool

Documentation

Index

• func NewSubPool(priority Priority, pool *Pool)
• type Logic
• type Pool
  • func NewPool(maxWait, maxSubWait int) *Pool
  • func NewPoolWithFunc(maxWait, maxSubWait int, logic Logic) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) LoadWaitCount() int64
  • func (p *Pool) NewSubPool(priority Priority) *SubPool
  • func (p *Pool) NewSubPoolWithFunc(priority Priority, logic Logic) *SubPool
  • func (p *Pool) QueueCount() int64
  • func (p *Pool) Run(sign chan os.Signal, low, normal, high chan poolQueue)
  • func (p *Pool) Submit(priority Priority, i interface{})
  • func (p *Pool) SubmitWait(priority Priority, i interface{})
  • func (p *Pool) SubmitWithFunc(priority Priority, i interface{}, logic Logic)
  • func (p *Pool) SubmitWithFuncWait(priority Priority, i interface{}, logic Logic)
  • func (p *Pool) Wait()
• type Priority
• type SubPool
  • func NewSubPoolWithFunc(priority Priority, pool *Pool, logic Logic) *SubPool
  • func (p *SubPool) Close()
  • func (p *SubPool) SetLogic(logic Logic)
  • func (p *SubPool) Submit(i interface{})
  • func (p *SubPool) SubmitWait(i interface{})
  • func (p *SubPool) SubmitWithFunc(i interface{}, logic Logic)
  • func (p *SubPool) SubmitWithFuncWait(i interface{}, logic Logic)
  • func (p *SubPool) Wait()

Functions

func NewSubPool

func NewSubPool(priority Priority, pool *Pool)

Types

type Logic

type Logic func(i interface{})

type Pool

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

func NewPool

func NewPool(maxWait, maxSubWait int) *Pool

func NewPoolWithFunc

func NewPoolWithFunc(maxWait, maxSubWait int, logic Logic) *Pool

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) LoadWaitCount

func (p *Pool) LoadWaitCount() int64

func (*Pool) NewSubPool

func (p *Pool) NewSubPool(priority Priority) *SubPool

func (*Pool) NewSubPoolWithFunc

func (p *Pool) NewSubPoolWithFunc(priority Priority, logic Logic) *SubPool

func (*Pool) QueueCount

func (p *Pool) QueueCount() int64

func (*Pool) Run

func (p *Pool) Run(sign chan os.Signal, low, normal, high chan poolQueue)

func (*Pool) Submit

func (p *Pool) Submit(priority Priority, i interface{})

func (*Pool) SubmitWait

func (p *Pool) SubmitWait(priority Priority, i interface{})

func (*Pool) SubmitWithFunc

func (p *Pool) SubmitWithFunc(priority Priority, i interface{}, logic Logic)

func (*Pool) SubmitWithFuncWait

func (p *Pool) SubmitWithFuncWait(priority Priority, i interface{}, logic Logic)

func (*Pool) Wait

func (p *Pool) Wait()

type Priority

type Priority uint32

const (
	LowPriority Priority = iota
	NormalPriority
	HighPriority
)

type SubPool

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

func NewSubPoolWithFunc

func NewSubPoolWithFunc(priority Priority, pool *Pool, logic Logic) *SubPool

func (*SubPool) Close

func (p *SubPool) Close()

func (*SubPool) SetLogic

func (p *SubPool) SetLogic(logic Logic)

func (*SubPool) Submit

func (p *SubPool) Submit(i interface{})

func (*SubPool) SubmitWait

func (p *SubPool) SubmitWait(i interface{})

func (*SubPool) SubmitWithFunc

func (p *SubPool) SubmitWithFunc(i interface{}, logic Logic)

func (*SubPool) SubmitWithFuncWait

func (p *SubPool) SubmitWithFuncWait(i interface{}, logic Logic)

func (*SubPool) Wait

func (p *SubPool) Wait()