pool

Documentation

Index

• type ObjPool
  • func NewObjPool(new func() typedef.Poolable) *ObjPool
  • func (o *ObjPool) Ask() typedef.Poolable
  • func (o *ObjPool) Giveback(p typedef.Poolable)
• type WorkPool
  • func NewWorkPool(maxIdle int, maxIdleTime time.Duration) *WorkPool
  • func (wp *WorkPool) Submit(t typedef.Task, p interface{})
  • func (wp *WorkPool) SubmitWait(t typedef.Task, p interface{})

Types

type ObjPool

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

func NewObjPool

func NewObjPool(new func() typedef.Poolable) *ObjPool

NewObjPool construct a new object pool

func (*ObjPool) Ask

func (o *ObjPool) Ask() typedef.Poolable

func (*ObjPool) Giveback

func (o *ObjPool) Giveback(p typedef.Poolable)

type WorkPool

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

WorkPool is a work pool that bind to some idl goroutines and put task to run.

func NewWorkPool

func NewWorkPool(maxIdle int, maxIdleTime time.Duration) *WorkPool

NewWorkPool construct a new work pool

func (*WorkPool) Submit

func (wp *WorkPool) Submit(t typedef.Task, p interface{})

Submit a task and run

func (*WorkPool) SubmitWait

func (wp *WorkPool) SubmitWait(t typedef.Task, p interface{})

SubmitWait submit the task and wait it util finish