sync

Documentation

Index

• type BoundedWaitGroup
  • func NewBoundedWaitGroup(cap int) BoundedWaitGroup
  • func (bwg *BoundedWaitGroup) Add(delta int)
  • func (bwg *BoundedWaitGroup) Done()
  • func (bwg *BoundedWaitGroup) Wait()
• type Waiter
  • func NewWaiter(cap int) Waiter

Types

type BoundedWaitGroup

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

BoundedWaitGroup is a wait group which has a limit boundary meaning it will wait for Done() to be called before releasing Add(n) if the limit has been reached

func NewBoundedWaitGroup

func NewBoundedWaitGroup(cap int) BoundedWaitGroup

NewBoundedWaitGroup returns a new BoundedWaitGroup

func (*BoundedWaitGroup) Add

func (bwg *BoundedWaitGroup) Add(delta int)

Add ...

func (*BoundedWaitGroup) Done

func (bwg *BoundedWaitGroup) Done()

Done ...

func (*BoundedWaitGroup) Wait

func (bwg *BoundedWaitGroup) Wait()

Wait ...

type Waiter

type Waiter interface {
	Add(int)
	Done()
	Wait()
}

Waiter interface

func NewWaiter

func NewWaiter(cap int) Waiter

NewWaiter returns a Waiter, a sync.WaitGroup if cap i <= 0, a BoundedWaitGroup otherwise.