ants

Documentation

Index

• func Go(task func())
• func NewPool(size int, options ...PoolOption)
• func Pool() *ants.Pool
• type PoolConfig
  • func Config() *PoolConfig
• type PoolLogger
• type PoolOption
  • func WithExpiryDuration(t time.Duration) PoolOption
  • func WithLogger(logger PoolLogger) PoolOption
  • func WithPanicHandler(h func(interface{})) PoolOption
  • func WithSubmitInterval(t time.Duration) PoolOption
  • func WithSubmitTimeout(t time.Duration) PoolOption

Functions

func Go

func Go(task func())

func NewPool

func NewPool(size int, options ...PoolOption)

func Pool

func Pool() *ants.Pool

Types

type PoolConfig

type PoolConfig struct {
	ExpiryDuration time.Duration
	SubmitTimeout  time.Duration
	SubmitInterval time.Duration
	Logger         PoolLogger
	PanicHandler   func(interface{})
}

func Config

func Config() *PoolConfig

type PoolLogger

type PoolLogger interface {
	ants.Logger
	SendMessage(msg string)
	LogName() string
}

type PoolOption

type PoolOption func(c *PoolConfig)

func WithExpiryDuration

func WithExpiryDuration(t time.Duration) PoolOption

func WithLogger

func WithLogger(logger PoolLogger) PoolOption

func WithPanicHandler

func WithPanicHandler(h func(interface{})) PoolOption

func WithSubmitInterval

func WithSubmitInterval(t time.Duration) PoolOption

func WithSubmitTimeout

func WithSubmitTimeout(t time.Duration) PoolOption