syncmap

type Lock ¶

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

func (l *Lock) Unlock()

type LockMap ¶

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

LockMap is a map of mutexes that automatically allocates and deallocates mutexes as necessary. It allows for fine-grained mutual exclusion for a potentially large key space, while only consuming space propotional to the number of acquired mutexes. The zero-initialised LockMap is ready to use.

func (m *LockMap) Lock(key string) *Lock

type Semaphore ¶

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

func (s *Semaphore) Release(n int64)

type SemaphoreMap ¶

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

SemaphoreMap is a map of semaphores that automatically allocates and deallocates semaphores as necessary. It allows for fine-grained semephore use, such as resource allocations and concurrent resource limits, for a potentially large key space, while only consuming space propotional to the number of acquired semaphores.

func NewSemaphoreMap(n int64) *SemaphoreMap

func (m *SemaphoreMap) Acquire(key string, n int64) *Semaphore

func (m *SemaphoreMap) AcquireContext(ctx context.Context, key string, n int64) (*Semaphore, error)

func (m *SemaphoreMap) TryAcquire(key string, n int64) *Semaphore