worker

Documentation

Index

• Variables
• type Do
• type ErrorHandler
• type Job
  • func MakeJob(do Do, timeout time.Duration, eh ErrorHandler) Job
• type Worker
  • func New(n int) *Worker
  • func (w *Worker) Push(job Job) error
  • func (w *Worker) Start()
  • func (w *Worker) Stop()

Variables

var (
	ErrWorkerIsStop = errors.New("Worker is stop")
	ErrNilJobDo     = errors.New("Job do field is nil")
)

错误

var DefaultWorker = New(defaultCount)

DefaultWorker 默认Wroker

Types

type Do

type Do func() error

Do 执行

type ErrorHandler

type ErrorHandler func(error)

ErrorHandler 错误处理方法

type Job

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

Job 工作

func MakeJob

func MakeJob(do Do, timeout time.Duration, eh ErrorHandler) Job

MakeJob 新建工作

type Worker

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

Worker 工人

func New

func New(n int) *Worker

New 新建

func (*Worker) Push

func (w *Worker) Push(job Job) error

Push 添加

func (*Worker) Start

func (w *Worker) Start()

Start 开始

func (*Worker) Stop

func (w *Worker) Stop()

Stop 停止