threadsafe

Documentation

Overview

Package threadsafe contains generic containers that are protected either by Mutexes or atomics underneath the hood.

Index

• type Map
  • func NewThreadSafeMap[K comparable, V any](m map[K]V) *Map[K, V]
  • func (m *Map[K, V]) Delete(k K)
  • func (m *Map[K, V]) Get(k K) (V, bool)
  • func (m *Map[K, V]) Keys() []K
  • func (m *Map[K, V]) Len() int
  • func (m *Map[K, V]) Put(k K, v V)

Types

type Map

type Map[K comparable, V any] struct {
	// contains filtered or unexported fields
}

Map implements a simple thread-safe map protected by a mutex.

func NewThreadSafeMap

func NewThreadSafeMap[K comparable, V any](m map[K]V) *Map[K, V]

NewThreadSafeMap returns a thread-safe map instance from a normal map.

func (*Map[K, V]) Delete

func (m *Map[K, V]) Delete(k K)

Delete an item from a thread-safe map.

func (*Map[K, V]) Get

func (m *Map[K, V]) Get(k K) (V, bool)

Get an item from a thread-safe map.

func (*Map[K, V]) Keys

func (m *Map[K, V]) Keys() []K

Keys returns the keys of a thread-safe map.

func (*Map[K, V]) Len

func (m *Map[K, V]) Len() int

Len of the thread-safe map.

func (*Map[K, V]) Put

func (m *Map[K, V]) Put(k K, v V)

Put an item into a thread-safe map.