pool

Documentation

Overview

Package pool littlerpc自带的goroutine池

Index

• Constants
• type DynamicTaskPool
  • func (p *DynamicTaskPool[Key]) BufSize() int
  • func (p *DynamicTaskPool[Key]) ExecuteError() int
  • func (p *DynamicTaskPool[Key]) ExecuteSuccess() int
  • func (p *DynamicTaskPool[Key]) LiveSize() int
  • func (p *DynamicTaskPool[Key]) Push(key Key, fn func()) error
  • func (p *DynamicTaskPool[Key]) Stop() error
• type FixedPool
  • func (h *FixedPool[Key]) BufSize() int
  • func (h *FixedPool[Key]) ExecuteError() int
  • func (h *FixedPool[Key]) ExecuteSuccess() int
  • func (h *FixedPool[Key]) LiveSize() int
  • func (h *FixedPool[Key]) Push(key Key, f func()) error
  • func (h *FixedPool[Key]) Stop() error
• type Hash
• type RecoverFunc
• type TaskPool
  • func NewFixedPool[Key Hash](bufSize, minSize, maxSize int32, rf RecoverFunc) TaskPool[Key]
  • func NewTaskPool[Key Hash](bufSize, minSize, maxSize int32, rf RecoverFunc) TaskPool[Key]
• type TaskPoolBuilder

Constants

const (
	MaxTaskPoolSize = 1024 * 16
)

Types

type DynamicTaskPool

type DynamicTaskPool[Key Hash] struct {
	// contains filtered or unexported fields
}

DynamicTaskPool v0.10 -> v0.36 实现了简单的任务池 v0.38 -> now 实现了可自动扩容的Goroutine池和可拓展的接口

func (*DynamicTaskPool[Key]) BufSize

func (p *DynamicTaskPool[Key]) BufSize() int

func (*DynamicTaskPool[Key]) ExecuteError

func (p *DynamicTaskPool[Key]) ExecuteError() int

func (*DynamicTaskPool[Key]) ExecuteSuccess

func (p *DynamicTaskPool[Key]) ExecuteSuccess() int

func (*DynamicTaskPool[Key]) LiveSize

func (p *DynamicTaskPool[Key]) LiveSize() int

func (*DynamicTaskPool[Key]) Push

func (p *DynamicTaskPool[Key]) Push(key Key, fn func()) error

func (*DynamicTaskPool[Key]) Stop

func (p *DynamicTaskPool[Key]) Stop() error

type FixedPool

type FixedPool[Key Hash] struct {
	// contains filtered or unexported fields
}

func (*FixedPool[Key]) BufSize

func (h *FixedPool[Key]) BufSize() int

func (*FixedPool[Key]) ExecuteError

func (h *FixedPool[Key]) ExecuteError() int

func (*FixedPool[Key]) ExecuteSuccess

func (h *FixedPool[Key]) ExecuteSuccess() int

func (*FixedPool[Key]) LiveSize

func (h *FixedPool[Key]) LiveSize() int

func (*FixedPool[Key]) Push

func (h *FixedPool[Key]) Push(key Key, f func()) error

func (*FixedPool[Key]) Stop

func (h *FixedPool[Key]) Stop() error

type Hash

type Hash interface {
	string | []byte | int64 | uint64
}

type RecoverFunc

type RecoverFunc func(poolId int, err interface{})

type TaskPool

type TaskPool[Key Hash] interface {
	Push(Key, func()) error
	Stop() error
	// LiveSize 存活的goroutine数量
	LiveSize() int
	// BufSize 缓冲区中存在的任务数量
	BufSize() int
	// ExecuteSuccess 任务池执行成功的任务数量
	ExecuteSuccess() int
	// ExecuteError 任务池执行失败的任务数量
	ExecuteError() int
}

func NewFixedPool

func NewFixedPool[Key Hash](bufSize, minSize, maxSize int32, rf RecoverFunc) TaskPool[Key]

func NewTaskPool

func NewTaskPool[Key Hash](bufSize, minSize, maxSize int32, rf RecoverFunc) TaskPool[Key]

type TaskPoolBuilder

type TaskPoolBuilder[Key Hash] interface {
	Builder(bufSize, minSize, maxSize int32, rf RecoverFunc) TaskPool[Key]
}