routine

Documentation

Index

• func AddCancel(cancel func()) (ctx context.Context)
• func AddCloser(c closeFunc)
• func DebugString() string
• func GoWork(f func())
• func IsStopped() <-chan struct{}
• func LogPanic(r interface{})
• func RunWork(name string, f func() error, panicHandler ...func(interface{})) error
• func RunWorkAsync(name string, f func(), panicHandler ...func(interface{})) error
• func RunWorkDaemon(name string, f func(), quit <-chan struct{}) error
• func ShouldStop() <-chan struct{}
• func Stop() error
• func WorkNum() int64

Functions

func AddCancel

func AddCancel(cancel func()) (ctx context.Context)

AddCancel addcancel hook

func AddCloser

func AddCloser(c closeFunc)

AddCloser add close hook

func DebugString

func DebugString() string

DebugString return the debug string

func GoWork

func GoWork(f func())

GoWork execute the f function in a routine, The routine is reused.

func IsStopped

func IsStopped() <-chan struct{}

IsStopped return the service has stopped

func LogPanic

func LogPanic(r interface{})

func RunWork

func RunWork(name string, f func() error, panicHandler ...func(interface{})) error

RunWork run the func in the same routine

func RunWorkAsync

func RunWorkAsync(name string, f func(), panicHandler ...func(interface{})) error

RunWorkAsync run the func in new routine

func RunWorkDaemon

func RunWorkDaemon(name string, f func(), quit <-chan struct{}) error

RunWorkDaemon run the func in new routine and run until stop

func ShouldStop

func ShouldStop() <-chan struct{}

ShouldStop return the service is stopping

func Stop

func Stop() error

Stop stop the service and wait all worker exit

func WorkNum

func WorkNum() int64

WorkNum return current number of works