npool

Documentation

Index

• type Pool
  • func New(name string, size int) *Pool
  • func (p *Pool) Get(ctx context.Context) (*Worker, error)
• type Worker
  • func (w Worker) Done()
  • func (w Worker) String() string

Types

type Pool

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

func New

func New(name string, size int) *Pool

New constructs a new worker pool of the specified size.

func (*Pool) Get

func (p *Pool) Get(ctx context.Context) (*Worker, error)

type Worker

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

Worker represents the permission to do work.

func (Worker) Done

func (w Worker) Done()

Done returns this worker to the pool.

func (Worker) String

func (w Worker) String() string

String returns the name & ID of this worker.