worker

Documentation

Index

• Variables
• type Job
• type Option
  • func WithDropQueue(drop bool) Option
  • func WithMaxQueueSize(num int) Option
  • func WithMaxWorkersCount(num int) Option
• type WorkerPool
  • func New(opts ...Option) *WorkerPool
  • func (wp *WorkerPool) Release()
  • func (wp *WorkerPool) Run(job Job) error

Variables

var ErrWorkerPoolFull = errors.New("Job queue is full now, this Job will be droped")

Types

type Job

type Job func()

type Option

type Option func(*options)

Option 可选参数

func WithDropQueue

func WithDropQueue(drop bool) Option

func WithMaxQueueSize

func WithMaxQueueSize(num int) Option

func WithMaxWorkersCount

func WithMaxWorkersCount(num int) Option

type WorkerPool

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

WorkerPool 协程池实现

func New

func New(opts ...Option) *WorkerPool

New 根据选项新建一个协程池

func (*WorkerPool) Release

func (wp *WorkerPool) Release()

func (*WorkerPool) Run

func (wp *WorkerPool) Run(job Job) error

Run 通过协程池执行带处理任务 如果工作池满，返回ErrWorkerPoolFull错误，f将被丢弃，业务方可自行判断是否进行等待重试