workpool

Documentation

Index

• type ExecutionFn
• type Job
• type JobDescriptor
• type Result
• type Worker
• type WorkerPool
  • func NewWorkerPool(workers int) *WorkerPool
  • func (p *WorkerPool) AddJob(jobs ...Job)
  • func (p *WorkerPool) Done() <-chan struct{}
  • func (p *WorkerPool) IsFinished() bool
  • func (p *WorkerPool) Release()
  • func (p *WorkerPool) Results() <-chan Result
  • func (p *WorkerPool) Run(ctx context.Context)

Types

type ExecutionFn

type ExecutionFn func(ctx context.Context, args interface{}) (interface{}, error)

job 执行函数签名

type Job

type Job struct {
	Descriptor JobDescriptor
	ExecFn     ExecutionFn
	Args       interface{}
}

type JobDescriptor

type JobDescriptor struct {
	ID       string
	JobType  string
	Metadata map[string]interface{}
}

type Result

type Result struct {
	Value      interface{}
	Error      error
	Descriptor JobDescriptor
}

type Worker

type Worker struct {
	ID string
}

type WorkerPool

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

WorkerPool is a worker group that runs a number of workers at a configured concurrency.

func NewWorkerPool

func NewWorkerPool(workers int) *WorkerPool

NewWorkerPool initializes a new pool with the given number of Workers.

func (*WorkerPool) AddJob

func (p *WorkerPool) AddJob(jobs ...Job)

func (*WorkerPool) Done

func (p *WorkerPool) Done() <-chan struct{}

func (*WorkerPool) IsFinished

func (p *WorkerPool) IsFinished() bool

func (*WorkerPool) Release

func (p *WorkerPool) Release()

func (*WorkerPool) Results

func (p *WorkerPool) Results() <-chan Result

func (*WorkerPool) Run

func (p *WorkerPool) Run(ctx context.Context)