pool

Documentation

Index

• type DoFn
• 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 Option
  • func MaxRequestBufOpt(num int) Option
  • func MaxRequestTempBufOpt(num int) Option
  • func MaxTempWorkerOpt(num int) Option
  • func MaxTickCountOpt(num int) Option
  • func MinWorkerOpt(num int) Option
  • func TickWaitTimeOpt(duration time.Duration) Option
  • func WorkerHookOpt(h WorkerHook) Option
• type RespFn
• type ResponseFn
• type RunFn
• type WorkerHook

Types

type DoFn

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

DoFn[T, R] 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 GoroutinePool[T, R] instance

type Option

type Option = func(opt *gorotinePoolOpt)

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

func MaxRequestBufOpt

func MaxRequestBufOpt(num int) Option

MaxRequestBufOpt set max request buffer size

func MaxRequestTempBufOpt

func MaxRequestTempBufOpt(num int) Option

MaxRequestTempBufOpt set max request temp buffer size

func MaxTempWorkerOpt

func MaxTempWorkerOpt(num int) Option

func MaxTickCountOpt

func MaxTickCountOpt(num int) Option

MaxTickCountOpt set max tick count

func MinWorkerOpt

func MinWorkerOpt(num int) Option

MinWorkerOpt set min worker

func TickWaitTimeOpt

func TickWaitTimeOpt(duration time.Duration) Option

TickWaitTimeOpt set tick wait time

func WorkerHookOpt

func WorkerHookOpt(h WorkerHook) Option

WorkerHookOpt 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 WorkerHook

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

WorkerHook hook worker status