concurrent

Documentation

Index

• Constants
• Variables
• type Executor
• type Map
  • func NewMap() *Map
• type UnboundedExecutor
  • func NewUnboundedExecutor() *UnboundedExecutor
  • func (executor *UnboundedExecutor) Go(handler func(ctx context.Context))
  • func (executor *UnboundedExecutor) Stop()
  • func (executor *UnboundedExecutor) StopAndWait(ctx context.Context)
  • func (executor *UnboundedExecutor) StopAndWaitForever()

Constants

const StopSignal = "STOP!"

Variables

var GlobalUnboundedExecutor = NewUnboundedExecutor()

GlobalUnboundedExecutor has the life cycle of the program itself any goroutine want to be shutdown before main exit can be started from this executor

var LogInfo = func(event string, properties ...interface{}) {
}

var LogPanic = func(recovered interface{}, properties ...interface{}) interface{} {
	fmt.Println(fmt.Sprintf("paniced: %v", recovered))
	debug.PrintStack()
	return recovered
}

Types

type Executor

type Executor interface {
	Go(handler func(ctx context.Context))
}

type Map

type Map struct {
	sync.Map
}

func NewMap

func NewMap() *Map

type UnboundedExecutor

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

func NewUnboundedExecutor

func NewUnboundedExecutor() *UnboundedExecutor

func (*UnboundedExecutor) Go

func (executor *UnboundedExecutor) Go(handler func(ctx context.Context))

func (*UnboundedExecutor) Stop

func (executor *UnboundedExecutor) Stop()

func (*UnboundedExecutor) StopAndWait

func (executor *UnboundedExecutor) StopAndWait(ctx context.Context)

func (*UnboundedExecutor) StopAndWaitForever

func (executor *UnboundedExecutor) StopAndWaitForever()