schedgroup

Documentation

Index

• type Group
  • func New(ctx context.Context) *Group
  • func (g *Group) Delay(delay time.Duration, fn func())
  • func (g *Group) Schedule(when time.Time, fn func())
  • func (g *Group) Wait() error

Types

type Group

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

A Group is a goroutine worker pool which schedules tasks to be performed after a specified time. A Group must be created with the New constructor.

func New

func New(ctx context.Context) *Group

New creates a new Group which will use ctx for cancelation.

func (*Group) Delay

func (g *Group) Delay(delay time.Duration, fn func())

Delay schedules a function to run at or after the specified delay. Delay is a convenience wrapper for Schedule which adds delay to the current time.

func (*Group) Schedule

func (g *Group) Schedule(when time.Time, fn func())

Schedule schedules a function to run at or after the specified time.

func (*Group) Wait

func (g *Group) Wait() error

Wait waits for the completion of all scheduled tasks, or for context cancelation.