wpool

Documentation

Index

• type Pool
  • func New(maxIdle int, maxIdleTime time.Duration) *Pool
  • func (p *Pool) Go(task Task)
  • func (p *Pool) GoCtx(ctx context.Context, task Task)
  • func (p *Pool) Size() int32
• type Task

Types

type Pool

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

Pool is a worker pool bind with some idle goroutines.

func New

func New(maxIdle int, maxIdleTime time.Duration) *Pool

New creates a new worker pool.

func (*Pool) Go

func (p *Pool) Go(task Task)

Go creates/reuses a worker to run task.

func (*Pool) GoCtx

func (p *Pool) GoCtx(ctx context.Context, task Task)

GoCtx creates/reuses a worker to run task.

func (*Pool) Size

func (p *Pool) Size() int32

Size returns the number of the running workers.

type Task

type Task func()

Task is the function that the worker will execute.