work

Documentation

Index

• type Option
  • func NumWorker(numWorker int) Option
  • func WorkProxy(workProxy func(ctx context.Context, handler WorkHandler)) Option
• type TaskFunc
• type WorkHandler
• type Worker
  • func NewWorker(f func()) *Worker
  • func (w *Worker) Done() <-chan struct{}
• type WorkerPool
  • func NewWorkerPool(size int, o ...Option) *WorkerPool
  • func (pool *WorkerPool) Close()
  • func (pool *WorkerPool) Run(task TaskFunc)
  • func (pool *WorkerPool) RunContext(ctx context.Context, task TaskFunc) error
  • func (pool *WorkerPool) TryRun(task TaskFunc) bool

Types

type Option

type Option func(*options)

func NumWorker

func NumWorker(numWorker int) Option

num of workers

func WorkProxy

func WorkProxy(workProxy func(ctx context.Context, handler WorkHandler)) Option

work proxy

type TaskFunc

type TaskFunc func(ctx context.Context)

type WorkHandler

type WorkHandler func(ctx context.Context)

type Worker

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

func NewWorker

func NewWorker(f func()) *Worker

func (*Worker) Done

func (w *Worker) Done() <-chan struct{}

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool(size int, o ...Option) *WorkerPool

func (*WorkerPool) Close

func (pool *WorkerPool) Close()

func (*WorkerPool) Run

func (pool *WorkerPool) Run(task TaskFunc)

func (*WorkerPool) RunContext

func (pool *WorkerPool) RunContext(ctx context.Context, task TaskFunc) error

func (*WorkerPool) TryRun

func (pool *WorkerPool) TryRun(task TaskFunc) bool