workerpool

Documentation

Index

• type HandlerGetter
• type Pool
  • func New(numWorkers int) *Pool
  • func (wp *Pool) AwaitShutdown()
  • func (wp *Pool) Start(ctx context.Context, taskQueue task.Dequeuer[task.Task], ...)

Types

type HandlerGetter

type HandlerGetter interface {
	Get(taskType string) (task.Handler, bool)
}

type Pool

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

func New

func New(numWorkers int) *Pool

func (*Pool) AwaitShutdown

func (wp *Pool) AwaitShutdown()

func (*Pool) Start

func (wp *Pool) Start(
	ctx context.Context,
	taskQueue task.Dequeuer[task.Task],
	results task.Submitter[task.Result],
	taskHandlers HandlerGetter,
)