conc

Documentation

Index

• type ContextPool
  • func NewConcContextPool(cfg PoolConfig) ContextPool
• type Main
  • func DefaultMain(max MaxGoroutines) Main
• type MaxGoroutines
• type Pool
  • func NewConcPool(maxGoroutines int) Pool
• type PoolConfig

Types

type ContextPool

type ContextPool interface {
	Go(f func(context.Context) error)
	Wait() error
}

func NewConcContextPool

func NewConcContextPool(cfg PoolConfig) ContextPool

type Main

type Main struct {
	NewPool        func(maxGoroutines int) Pool
	NewContextPool func(cfg PoolConfig) ContextPool
	MaxGoroutines  MaxGoroutines
}

func DefaultMain

func DefaultMain(max MaxGoroutines) Main

type MaxGoroutines

type MaxGoroutines uint

type Pool

type Pool interface {
	Go(f func())
	Wait()
}

func NewConcPool

func NewConcPool(maxGoroutines int) Pool

type PoolConfig

type PoolConfig struct {
	Context       context.Context
	MaxGoroutines int
}