gopool

Documentation

Index

• type Config
  • func NewConfig() *Config
• type Pool
  • func NewPool(name string, cap int32, config *Config) Pool

Types

type Config

type Config struct {
	ScaleThreshold int32
}

func NewConfig

func NewConfig() *Config

type Pool

type Pool interface {
	Name() string
	// SetCap sets the goroutine capacity of the pool.
	SetCap(cap int32)
	// Go executes f.
	Go(fn func(), panicHandler func(context.Context))
	// GoCtx executes f and accepts the context.
	GoCtx(ctx context.Context, f func(), panicHandler func(context.Context))
	// SetPanicHandler sets the panic handler.
	SetPanicHandler(f func(context.Context))
	// WorkerCount returns the number of running workers
	WorkerCount() int32
}

func NewPool

func NewPool(name string, cap int32, config *Config) Pool