wrapper

Documentation

Index

• func Register(wrapType WrapType, c constructor)
• type Option
  • func WithBufCap(c int) Option
  • func WithRecover(recoveryFunc func()) Option
• type Options
• type WrapType
• type Wrapper
  • func New(wrapType WrapType, opts ...Option) Wrapper
  • func NewChanWrapper(opts ...Option) Wrapper
  • func NewWgWrapper(opts ...Option) Wrapper

Functions

func Register

func Register(wrapType WrapType, c constructor)

Register register wrapper

Types

type Option

type Option func(o *Options)

Options optional function

func WithBufCap

func WithBufCap(c int) Option

WithBufCap set buf cap

func WithRecover

func WithRecover(recoveryFunc func()) Option

WithRecover set recover func

type Options

type Options struct {
	BufCap       int
	RecoveryFunc func()
}

Option wrapper option

type WrapType

type WrapType int

WrapType wrap type

const (
	// WgWrapper waitGroup wrapper
	WgWrapper WrapType = iota
	// ChWrapper chan wrapper
	ChWrapper
)

type Wrapper

type Wrapper interface {
	// Wrap exec func in goroutine without recover catch
	Wrap(fn func())

	// WrapWithRecover safely execute func in goroutine
	WrapWithRecover(fn func())

	// Wait this func wait all goroutine finish
	Wait()
}

Wrapper wrap goroutine to run

func New

func New(wrapType WrapType, opts ...Option) Wrapper

New create wrapper interface

func NewChanWrapper

func NewChanWrapper(opts ...Option) Wrapper

NewChanWrapper create wrapChanImpl entity If the wrapper using the chan method needs to specify the number of goroutines to be executed,the WithBufCap method needs to be called. Otherwise, after the Wait method is executed, some goroutines will exit without execution.

func NewWgWrapper

func NewWgWrapper(opts ...Option) Wrapper

NewWgWrapper create wrapper entity