pool

Documentation

Index

• type DoFn
• type ExecFn
• type GoroutinePool
  • func NewGoroutinePool[T, R any](fn DoFn[T, R], opts ...Option) GoroutinePool[T, R]
• type GoroutinePool2
  • func NewGoroutinePool2[T any](fn RunFn[T], opts ...Option) GoroutinePool2[T]
• type GoroutinePool3
  • func NewGoroutinePool3[T any](fn ExecFn[T], opts ...Option) GoroutinePool3[T]
• type Option
  • func WithMaxIdelTime(d time.Duration) Option
  • func WithMaxRequestBuf(num int) Option
  • func WithMaxRequestTempBuf(num int) Option
  • func WithMaxTempWorker(num int) Option
  • func WithMinWorker(num int) Option
  • func WithWorkerHook(h WorkerHook) Option
• type RespFn
• type ResponseFn
• type RunFn
• type WorkPool
  • func NewBufferWorkPool(maxIdle int, maxIdleTime time.Duration) WorkPool
  • func NewSimpleWorkPool(maxIdle int, maxIdleTime time.Duration) WorkPool
  • func NewWorkPool(maxIdle int, maxIdleTime time.Duration) WorkPool
• type WorkerHook

Types

type DoFn

type DoFn[T, R any] func(req T) (R, error)

DoFn[T, R] request handle function

type ExecFn

type ExecFn[T any] func(req T)

ExecFn[T] request handle function

type GoroutinePool

type GoroutinePool[T, R any] interface {
	Start()
	Stop()
	Do(T, ResponseFn[T, R])
}

GoroutinePool[T, R] goroutine pool interface

func NewGoroutinePool

func NewGoroutinePool[T, R any](fn DoFn[T, R], opts ...Option) GoroutinePool[T, R]

NewGoroutinePool[T, R] create a new GoroutinePool[T, R] instance

type GoroutinePool2

type GoroutinePool2[T any] interface {
	Start()
	Stop()
	Run(T, RespFn[T])
}

GoroutinePool2[T] goroutine pool interface

func NewGoroutinePool2

func NewGoroutinePool2[T any](fn RunFn[T], opts ...Option) GoroutinePool2[T]

NewGoroutinePool2[T] create a new GoroutinePool2[T] instance

type GoroutinePool3

type GoroutinePool3[T any] interface {
	Start()
	Stop()
	Exec(T)
}

GoroutinePool3[T] goroutine pool interface

func NewGoroutinePool3

func NewGoroutinePool3[T any](fn ExecFn[T], opts ...Option) GoroutinePool3[T]

NewGoroutinePool3[T] create a new GoroutinePool3[T] instance

type Option

type Option = func(opt *gorotinePoolOpt)

Option groutine pool option help function used to create groutine pool instance

func WithMaxIdelTime

func WithMaxIdelTime(d time.Duration) Option

WithMaxIdelTime set max idle time to custom a worker max wait tile to worker

func WithMaxRequestBuf

func WithMaxRequestBuf(num int) Option

WithMaxRequestBuf set max request buffer size

func WithMaxRequestTempBuf

func WithMaxRequestTempBuf(num int) Option

WithMaxRequestTempBuf set max request temp buffer size

func WithMaxTempWorker

func WithMaxTempWorker(num int) Option

WithMaxRequestBuf set max temp worker count

func WithMinWorker

func WithMinWorker(num int) Option

WithMinWorker set min worker count

func WithWorkerHook

func WithWorkerHook(h WorkerHook) Option

WithWorkerHookOpt set wroker hook

type RespFn

type RespFn[T any] func(req T, err error)

RespFn[T] response handle function

type ResponseFn

type ResponseFn[T, R any] func(req T, resp R, err error)

ResponseFn[T, R] response handle function

type RunFn

type RunFn[T any] func(req T) error

RunFn[T] request handle function

type WorkPool

type WorkPool interface {
	Go(fn types.Fn)
}

WorkPool work pool interface

func NewBufferWorkPool

func NewBufferWorkPool(maxIdle int, maxIdleTime time.Duration) WorkPool

NewBufferWorkPool create a work pool instance use buffer style

func NewSimpleWorkPool

func NewSimpleWorkPool(maxIdle int, maxIdleTime time.Duration) WorkPool

NewSimpleWorkPool create a work pool instance use simple style

func NewWorkPool

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

NewWorkPool create a work pool instance

type WorkerHook

type WorkerHook interface {
	OnJoin(count int32)
	OnLeave(count int32)
}

WorkerHook hook worker status