concurrency

package module

v1.0.1-0...-7c3cdd7 Latest Latest Go to latest Published: Aug 7, 2017 License: MIT Imports: 5 Imported by: 3

Details

This section is empty.

View Source

var (
	PoolClosedError = errors.New("pool closed")
	PoolIsFullError = errors.New("pool is full")
)

This section is empty.

type Config struct {
	Capacity     int
	IdleTimeout  time.Duration
	CloseTimeout time.Duration
}

Config is common for all pools

type Factory func() (Resource, error)

type Resource interface {
	io.Closer
}

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

func NewResourcePool(ctx context.Context, config Config, factory Factory) (p *ResourcePool)

func (p *ResourcePool) Close() (err error)

func (p *ResourcePool) Get(ctx context.Context) (r Resource, err error)

func (p *ResourcePool) Open() (err error)

func (p *ResourcePool) Put(r Resource) (err error)

func (p *ResourcePool) Wait() (err error)

type Worker struct {
	*supervisor.Control
	// contains filtered or unexported fields
}

func (w *Worker) Execute(ctx context.Context, fn func())

func (w *Worker) Open() (err error)

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

WorkerPool uses pool of workers to execute tasks

func NewWorkerPool(ctx context.Context, config Config) (p *WorkerPool)

func (p *WorkerPool) Close() (err error)

func (p *WorkerPool) Execute(ctx context.Context, fn func()) (err error)

func (p *WorkerPool) Get(ctx context.Context) (w *Worker, err error)

Take worker from pool

func (p *WorkerPool) Open() (err error)

func (p *WorkerPool) Put(w *Worker) (err error)

func (p *WorkerPool) Wait() (err error)