workers

Documentation

Index

• type WorkItem
• type Worker
  • func New(ctx context.Context, workers int, logger *mylog.MyLog) *Worker
  • func (w *Worker) Stop(ctx context.Context)
  • func (w *Worker) Submit(ctx context.Context, wi func(wid, jid int))

Types

type WorkItem

type WorkItem func()

WorkItem is an interface to work item used b the Workers

type Worker

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

Worker is a pool of workers.

func New

func New(ctx context.Context, workers int, logger *mylog.MyLog) *Worker

New creates a new worker pool with NumCPU runing workers

func (*Worker) Stop

func (w *Worker) Stop(ctx context.Context)

Stop stops all runing workers and wait them to finish and then leave the workerpool.

func (*Worker) Submit

func (w *Worker) Submit(ctx context.Context, wi func(wid, jid int))

Submit a work item to the worker pool