semaphore

Documentation

Overview

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.