gopool

Documentation

Index

• Variables
• type Option
  • func WithMaxIdleTimeoutSeconds(seconds int64) Option
  • func WithPanicHandler(panicHandler func(err interface{})) 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 interface{})) 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 _