schedgroup

Documentation

Index

• type Group
  • func New(ctx context.Context) *Group
  • func (g *Group) Delay(delay time.Duration, 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 delays tasks for a specified time.

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.

func (*Group) Wait

func (g *Group) Wait() error

Wait waits for the completion of all scheduled tasks.