gopool

Documentation

Index

• Variables
• type Option
  • func WithMaxIdleTimeoutSeconds(seconds int64) Option
  • func WithPanicHandler(panicHandler func(err any)) Option
  • func WithQueueLength(length int) Option
  • func WithSpawnSize(size int) Option
• type Options
• type Pool
  • func NewPool(maxWorkerNum int, opts ...Option) (*Pool, error)
  • func (p *Pool) ActiveWorkerNum() int64
  • func (p *Pool) FailedTotal() uint64
  • func (p *Pool) HandleTotal() uint64
  • func (p *Pool) PendingTaskTotal() int64
  • func (p *Pool) QueueLength() int64
  • func (p *Pool) Submit(task func()) error
  • func (p *Pool) SubmitTimeout(timeout time.Duration, task func()) error
  • func (p *Pool) SuccessTotal() uint64

Variables

var (
	ErrSubmitTimeout    = errors.New("submit error: timed out")
	ErrOptionsDeadQueue = errors.New("options error:dead queue configuration")
	ErrOptionsSpawn     = errors.New("options error:spawn > workers")
)

Types

type Option

type Option func(opts *Options)

func WithMaxIdleTimeoutSeconds

func WithMaxIdleTimeoutSeconds(seconds int64) Option

func WithPanicHandler

func WithPanicHandler(panicHandler func(err any)) Option

WithPanicHandler set panicHandler

func WithQueueLength

func WithQueueLength(length int) Option

WithQueueLength set queue length

func WithSpawnSize

func WithSpawnSize(size int) Option

WithSpawnSize set spawn size

type Options

type Options struct {
	// contains filtered or unexported fields
}

type Pool

type Pool struct {
	// contains filtered or unexported fields
}

Pool goroutine pool

func NewPool

func NewPool(maxWorkerNum int, opts ...Option) (*Pool, error)

func (*Pool) ActiveWorkerNum

func (p *Pool) ActiveWorkerNum() int64

ActiveWorkerNum get active worker number

func (*Pool) FailedTotal

func (p *Pool) FailedTotal() uint64

FailedTotal _

func (*Pool) HandleTotal

func (p *Pool) HandleTotal() uint64

HandleTotal _

func (*Pool) PendingTaskTotal

func (p *Pool) PendingTaskTotal() int64

PendingTaskTotal get pending task num

func (*Pool) QueueLength

func (p *Pool) QueueLength() int64

QueueLength get queue item number

func (*Pool) Submit

func (p *Pool) Submit(task func()) error

Submit _

func (*Pool) SubmitTimeout

func (p *Pool) SubmitTimeout(timeout time.Duration, task func()) error

SubmitTimeout _

func (*Pool) SuccessTotal

func (p *Pool) SuccessTotal() uint64

SuccessTotal _