sched

Documentation

Overview

Package sched contains primitives for scheduling

Index

• type Quota
  • func NewQuota(m int) *Quota
  • func (q *Quota) Begin() error
  • func (q *Quota) Close()
  • func (q *Quota) End()
  • func (q *Quota) Init(m int) *Quota

Types

type Quota

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

Quota behaves like sync.Mutex, except it allows up to a given limit of concurrent lock holders.

func NewQuota

func NewQuota(m int) *Quota

NewQuota creates a new quota with limit m.

func (*Quota) Begin

func (q *Quota) Begin() error

Lock blocks until there are fewer than limit unclosed sessions. A session begins when Open returns.

func (*Quota) Close

func (q *Quota) Close()

func (*Quota) End

func (q *Quota) End()

End undoes one previous Begin.

func (*Quota) Init

func (q *Quota) Init(m int) *Quota

Init resets this limiter and sets its limit to m.