upool

Documentation

Index

• Variables
• type TaskHandler
• type TaskPool
  • func NewTaskPool(max uint64) *TaskPool
  • func (tp *TaskPool) Close() bool
  • func (tp *TaskPool) GetImf() (uint64, uint64)
  • func (tp *TaskPool) Put(task TaskHandler)
  • func (tp *TaskPool) ResizeCap(delta int) error

Variables

var (
	ErrResizeDeltaInvalid error = errors.New("resize capacity with wrong delta number")
	ErrResizeUnable       error = errors.New("resize capacity unable now")
	ErrResizeExcuting     error = errors.New("resize capacity is excuting now")
)

Types

type TaskHandler

type TaskHandler interface {
	Execute()
}

type TaskPool

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

func NewTaskPool

func NewTaskPool(max uint64) *TaskPool

func (*TaskPool) Close

func (tp *TaskPool) Close() bool

func (*TaskPool) GetImf

func (tp *TaskPool) GetImf() (uint64, uint64)

返回 cap, running worker num(in goroutine)

func (*TaskPool) Put

func (tp *TaskPool) Put(task TaskHandler)

func (*TaskPool) ResizeCap

func (tp *TaskPool) ResizeCap(delta int) error