pool

Documentation

Overview

Package pool provides a worker pool that enforces an upper limit on concurrent workers.

It is intended for internal use by buildkite-agent only.

Index

• Constants
• type Pool
  • func New(concurrencyLimit int) *Pool
  • func (pool *Pool) Lock()
  • func (pool *Pool) Spawn(job func())
  • func (pool *Pool) Unlock()
  • func (pool *Pool) Wait()

Constants

const (
	MaxConcurrencyLimit = -1
)

Types

type Pool

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

func New

func New(concurrencyLimit int) *Pool

func (*Pool) Lock

func (pool *Pool) Lock()

func (*Pool) Spawn

func (pool *Pool) Spawn(job func())

func (*Pool) Unlock

func (pool *Pool) Unlock()

func (*Pool) Wait

func (pool *Pool) Wait()