goworker

Documentation

Index

• type EmptyStruct
• type WaitExitResult
• type Worker
  • func New(f WorkerThreadFunction) *Worker
  • func (self *Worker) Restart() WorkerControlChanResult
  • func (self *Worker) Start() WorkerControlChanResult
  • func (self *Worker) Status() *workerstatus.WorkerStatusRO
  • func (self *Worker) Stop() WorkerControlChanResult
  • func (self *Worker) Wait() WaitExitResult
• type WorkerControlChanResult
• type WorkerI
• type WorkerThreadFunction

Types

type EmptyStruct

type EmptyStruct struct{}

type WaitExitResult

type WaitExitResult chan EmptyStruct

type Worker

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

func New

func New(f WorkerThreadFunction) *Worker

func (*Worker) Restart

func (self *Worker) Restart() WorkerControlChanResult

func (*Worker) Start

func (self *Worker) Start() WorkerControlChanResult

func (*Worker) Status

func (self *Worker) Status() *workerstatus.WorkerStatusRO

func (*Worker) Stop

func (self *Worker) Stop() WorkerControlChanResult

func (*Worker) Wait

func (self *Worker) Wait() WaitExitResult

type WorkerControlChanResult

type WorkerControlChanResult chan EmptyStruct

type WorkerI

type WorkerI interface {
	Start() WorkerControlChanResult
	Stop() WorkerControlChanResult
	Restart() WorkerControlChanResult
	Status() *workerstatus.WorkerStatusRO
	Wait() WaitExitResult
}

type WorkerThreadFunction

type WorkerThreadFunction func(

	set_starting func(),
	set_working func(),
	set_stopping func(),
	set_stopped func(),

	is_stop_flag func() bool,

)