gopool

Documentation

Index

• Variables
• func CloseAndWait()
• func Go(f func(context.Context))
• type Config
  • func Configure() *Config
  • func (c *Config) Idle(time time.Duration) *Config
  • func (c *Config) Workers(max int) *Config
• type Pool
  • func New(ctx context.Context, cfgs ...*Config) *Pool
  • func (g *Pool) Close(grace bool)
  • func (g *Pool) Do(f func(context.Context)) *Pool
  • func (g *Pool) Done()

Variables

var GlobalConfig = Configure()

Functions

func CloseAndWait

func CloseAndWait()

func Go

func Go(f func(context.Context))

Types

type Config

type Config struct {
	Concurrent  int
	IdleTimeout time.Duration
}

func Configure

func Configure() *Config

func (*Config) Idle

func (c *Config) Idle(time time.Duration) *Config

func (*Config) Workers

func (c *Config) Workers(max int) *Config

type Pool

type Pool struct {
	Cfg *Config
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, cfgs ...*Config) *Pool

func (*Pool) Close

func (g *Pool) Close(grace bool)

Close will call context.Cancel(), so all goroutines maybe exit when job does not complete

func (*Pool) Do

func (g *Pool) Do(f func(context.Context)) *Pool

Do pick one idle goroutine to do the f once

func (*Pool) Done

func (g *Pool) Done()

Done will wait for all goroutines complete the jobs and then close the pool