gtask

Documentation

Index

• type Pool
  • func DefaultPool() *Pool
  • func NewPool() *Pool
  • func (p *Pool) AddTask(fn taskFunc, interval time.Duration)
  • func (p *Pool) Start(ctx context.Context)
  • func (p *Pool) Stop()

Types

type Pool

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

Pool is the task pool for managing some async jobs.

func DefaultPool

func DefaultPool() *Pool

func NewPool

func NewPool() *Pool

func (*Pool) AddTask

func (p *Pool) AddTask(fn taskFunc, interval time.Duration)

func (*Pool) Start

func (p *Pool) Start(ctx context.Context)

func (*Pool) Stop

func (p *Pool) Stop()