zzzz

Documentation

Index

• type Pool
  • func NewWorkerPool(size int) (*Pool, error)
  • func NewWorkerPoolWithOptions(size int, options ...ants.Option) (*Pool, error)
  • func (p *Pool) Release()
  • func (p *Pool) Running() int
  • func (p *Pool) Submit(task func()) error
  • func (p *Pool) Tune(size int)
• type WorkerLogger
  • func (WorkerLogger) Printf(format string, args ...interface{})

Types

type Pool

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

Pool alias of ants.Pool

func NewWorkerPool

func NewWorkerPool(size int) (*Pool, error)

NewWorkerPool constructor of Pool

func NewWorkerPoolWithOptions

func NewWorkerPoolWithOptions(size int, options ...ants.Option) (*Pool, error)

NewWorkerPoolWithOptions 创建Worker池, 支持传入ants Option.

func (*Pool) Release

func (p *Pool) Release()

Release close pool and release resources

func (*Pool) Running

func (p *Pool) Running() int

Running return goroutines of runnning

func (*Pool) Submit

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

Submit submit a task

func (*Pool) Tune

func (p *Pool) Tune(size int)

Tune 调整Worker池容量

type WorkerLogger

type WorkerLogger struct {
}

WorkerLogger log handler

func (WorkerLogger) Printf

func (WorkerLogger) Printf(format string, args ...interface{})

Printf implements ants.Logger