limiter

Documentation

Overview

Package limiter provides concurrency limiters.

Index

• type Fixed
  • func NewFixed(limit int) Fixed
  • func (t Fixed) Release()
  • func (t Fixed) Take()

Types

type Fixed

type Fixed chan struct{}

Fixed is a simple channel-based concurrency limiter. It uses a fixed size channel to limit callers from proceeding until there is a value available in the channel. If all are in-use, the caller blocks until one is freed.

func NewFixed

func NewFixed(limit int) Fixed

func (Fixed) Release

func (t Fixed) Release()

func (Fixed) Take

func (t Fixed) Take()