async

Documentation

Index

• Variables
• type Option
  • func Buffer(n int) Option
  • func Worker(n int) Option
• type TaskDispatcher
  • func New(name string, opts ...Option) *TaskDispatcher
  • func (c *TaskDispatcher) Close() error
  • func (c *TaskDispatcher) Dispatch(ctx context.Context, taskFn func(ctx context.Context)) (err error)

Variables

var (
	// ErrFull chan full.
	ErrFull = errors.New("async: chan full")
)

Types

type Option

type Option func(*options)

Option TaskDispatcher option

func Buffer

func Buffer(n int) Option

Buffer specifies the buffer of TaskDispatcher

func Worker

func Worker(n int) Option

Worker specifies the worker of TaskDispatcher

type TaskDispatcher

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

TaskDispatcher async consume data from chan.

func New

func New(name string, opts ...Option) *TaskDispatcher

New new a TaskDispatcher struct.

func (*TaskDispatcher) Close

func (c *TaskDispatcher) Close() error

Close 必须显示调用, 防止丢 task

func (*TaskDispatcher) Dispatch

func (c *TaskDispatcher) Dispatch(ctx context.Context, taskFn func(ctx context.Context)) (err error)

Dispatch 分发调度 save a callback func.