package semaphore

import "github.com/purpleidea/mgmt/util/semaphore"

Package semaphore contains an implementation of a counting semaphore.

Index ¶

• type Semaphore
• func NewSemaphore(size int) *Semaphore
• func (obj *Semaphore) Close()
• func (obj *Semaphore) Init(size int)
• func (obj *Semaphore) P(n int) error
• func (obj *Semaphore) V(n int) error

Types ¶

type Semaphore ¶

type Semaphore struct {
	C chan struct{}
	// contains filtered or unexported fields
}

Semaphore is a counting semaphore. It must be initialized before use.

func NewSemaphore ¶

func NewSemaphore(size int) *Semaphore

NewSemaphore creates a new semaphore.

func (*Semaphore) Close ¶

func (obj *Semaphore) Close()

Close shuts down the semaphore and releases all the locks.

func (*Semaphore) Init ¶

func (obj *Semaphore) Init(size int)

Init initializes the semaphore.

func (*Semaphore) P ¶

func (obj *Semaphore) P(n int) error

P acquires n resources.

func (*Semaphore) V ¶

func (obj *Semaphore) V(n int) error

V releases n resources.

Source Files ¶

semaphore.go