semaphore

Documentation

Overview

Package semaphore implements a basic semaphore for coordinating and limiting non-exclusive, concurrent access.

Index

• type Semaphore
  • func New(concurrency int) Semaphore
  • func (s Semaphore) Acquire()
  • func (s Semaphore) Release()

Types

type Semaphore

type Semaphore chan struct{}

func New

func New(concurrency int) Semaphore

New creates a semaphore with the given concurrency limit.

func (Semaphore) Acquire

func (s Semaphore) Acquire()

Acquire will block until the semaphore can be acquired.

func (Semaphore) Release

func (s Semaphore) Release()

Release frees the acquired slot in the semaphore.