workpool

Documentation

Index

• type HybridPool
  • func NewHybridPool(minWorkers, maxWorkers int) *HybridPool
  • func (p *HybridPool) Close()
  • func (p *HybridPool) Spawn()
  • func (p *HybridPool) Submit(ctx context.Context, task Task) error
  • func (p *HybridPool) Wait()
• type Task

Types

type HybridPool

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

func NewHybridPool

func NewHybridPool(minWorkers, maxWorkers int) *HybridPool

func (*HybridPool) Close

func (p *HybridPool) Close()

func (*HybridPool) Spawn

func (p *HybridPool) Spawn()

func (*HybridPool) Submit

func (p *HybridPool) Submit(ctx context.Context, task Task) error

func (*HybridPool) Wait

func (p *HybridPool) Wait()

type Task

type Task interface{ Do() }