sem

Documentation

Overview

Package sem provides safe concurrent access to a bounded pool of resources.

Index

• type Pool
  • func NewPool(items ...interface{}) *Pool
  • func (p *Pool) Acquire(ctx context.Context, n int) ([]interface{}, error)
  • func (p *Pool) Release(items []interface{})

Types

type Pool

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

Pool provides concurrent access to a fixed bounded pool of resources

func NewPool

func NewPool(items ...interface{}) *Pool

NewPool builds a pool providing concurrent access to the given items.

func (*Pool) Acquire

func (p *Pool) Acquire(ctx context.Context, n int) ([]interface{}, error)

Acquire n items from the pool. Blocks until the requested items are available or the context is cancelled.

func (*Pool) Release

func (p *Pool) Release(items []interface{})

Release returns items to the pool.