routine

Documentation

Index

• func RunSync(ctx context.Context, prob *Routine, f func(ctx context.Context)) bool
• func WrapCloser(pb *Routine) closes.WithContextCloser
• type Routine
  • func New(f func(ctx context.Context)) *Routine
  • func (r *Routine) IsRunning() bool
  • func (r *Routine) IsStopped() bool
  • func (r *Routine) Running() <-chan struct{}
  • func (r *Routine) Start() bool
  • func (r *Routine) Stop()
  • func (r *Routine) StopAccepted() bool
  • func (r *Routine) StopAndWait(ctx context.Context) error
  • func (r *Routine) StopAndWaitDuration(duration time.Duration) error
  • func (r *Routine) Stopped() chan struct{}

Functions

func RunSync

func RunSync(ctx context.Context, prob *Routine, f func(ctx context.Context)) bool

func WrapCloser

func WrapCloser(pb *Routine) closes.WithContextCloser

Types

type Routine

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

a easy manager go routine based on goroutine

func New

func New(f func(ctx context.Context)) *Routine

func (*Routine) IsRunning

func (r *Routine) IsRunning() bool

func (*Routine) IsStopped

func (r *Routine) IsStopped() bool

func (*Routine) Running

func (r *Routine) Running() <-chan struct{}

func (*Routine) Start

func (r *Routine) Start() bool

func (*Routine) Stop

func (r *Routine) Stop()

func (*Routine) StopAccepted

func (r *Routine) StopAccepted() bool

func (*Routine) StopAndWait

func (r *Routine) StopAndWait(ctx context.Context) error

func (*Routine) StopAndWaitDuration

func (r *Routine) StopAndWaitDuration(duration time.Duration) error

func (*Routine) Stopped

func (r *Routine) Stopped() chan struct{}