syncutil

Documentation

Overview

Package syncutil adds functions for synchronization.

Index

• func Wait(ctx context.Context, wg *sync.WaitGroup) error
• type Map
  • func NewMap[K comparable, V any]() Map[K, V]
  • func (sm *Map[K, V]) Get(k K) (V, bool)
  • func (sm *Map[K, V]) Range(fn func(K, V) bool)
  • func (sm *Map[K, V]) Store(k K, v V)

Functions

func Wait

func Wait(ctx context.Context, wg *sync.WaitGroup) error

Wait for a sync.WaitGroup with support for timeout/cancellations from context.

Types

type Map

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

Map a generic sync map.

func NewMap

func NewMap[K comparable, V any]() Map[K, V]

NewMap create a new threadsafe map.

func (*Map[K, V]) Get

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

Get a value from this map.

func (*Map[K, V]) Range

func (sm *Map[K, V]) Range(fn func(K, V) bool)

Range iterate the map.

func (*Map[K, V]) Store

func (sm *Map[K, V]) Store(k K, v V)

Store a value in this map.