xsync

Aug 21, 2023

Changes in this version

+ type MPMCQueueOf struct

+ func NewMPMCQueueOf(capacity int) *MPMCQueueOf[I]

+ func (q *MPMCQueueOf[I]) Dequeue() I

+ func (q *MPMCQueueOf[I]) Enqueue(item I)

+ func (q *MPMCQueueOf[I]) TryDequeue() (item I, ok bool)

+ func (q *MPMCQueueOf[I]) TryEnqueue(item I) bool

Nov 8, 2022

Changes in this version

type Map

+ func NewMapPresized(sizeHint int) *Map

type MapOf

+ func NewIntegerMapOfPresized(sizeHint int) *MapOf[K, V]

+ func NewMapOfPresized(sizeHint int) *MapOf[string, V]

+ func NewTypedMapOfPresized(hasher func(maphash.Seed, K) uint64, sizeHint int) *MapOf[K, V]

Oct 31, 2022

Changes in this version

type RBMutex

+ func NewRBMutex() *RBMutex

Oct 30, 2022

Changes in this version

type Counter

+ func NewCounter() *Counter

Oct 29, 2022

Changes in this version

type Map

+ func (m *Map) Clear()

+ func (m *Map) Compute(key string, ...) (actual interface{}, ok bool)

type MapOf

+ func (m *MapOf[K, V]) Clear()

+ func (m *MapOf[K, V]) Compute(key K, valueFn func(oldValue V, loaded bool) (newValue V, delete bool)) (actual V, ok bool)

Oct 26, 2022

Changes in this version

+ type Counter struct

+ func (c *Counter) Add(delta int64)

+ func (c *Counter) Dec()

+ func (c *Counter) Inc()

+ func (c *Counter) Reset()

+ func (c *Counter) Value() int64

+ type IntegerConstraint interface

+ type MPMCQueue struct

+ func NewMPMCQueue(capacity int) *MPMCQueue

+ func (q *MPMCQueue) Dequeue() interface{}

+ func (q *MPMCQueue) Enqueue(item interface{})

+ func (q *MPMCQueue) TryDequeue() (item interface{}, ok bool)

+ func (q *MPMCQueue) TryEnqueue(item interface{}) bool

+ type Map struct

+ func NewMap() *Map

+ func (m *Map) Delete(key string)

+ func (m *Map) Load(key string) (value interface{}, ok bool)

+ func (m *Map) LoadAndDelete(key string) (value interface{}, loaded bool)

+ func (m *Map) LoadAndStore(key string, value interface{}) (actual interface{}, loaded bool)

+ func (m *Map) LoadOrCompute(key string, valueFn func() interface{}) (actual interface{}, loaded bool)

+ func (m *Map) LoadOrStore(key string, value interface{}) (actual interface{}, loaded bool)

+ func (m *Map) Range(f func(key string, value interface{}) bool)

+ func (m *Map) Size() int

+ func (m *Map) Store(key string, value interface{})

+ type MapOf struct

+ func NewIntegerMapOf() *MapOf[K, V]

+ func NewMapOf() *MapOf[string, V]

+ func NewTypedMapOf(hasher func(maphash.Seed, K) uint64) *MapOf[K, V]

+ func (m *MapOf[K, V]) Delete(key K)

+ func (m *MapOf[K, V]) Load(key K) (value V, ok bool)

+ func (m *MapOf[K, V]) LoadAndDelete(key K) (value V, loaded bool)

+ func (m *MapOf[K, V]) LoadAndStore(key K, value V) (actual V, loaded bool)

+ func (m *MapOf[K, V]) LoadOrCompute(key K, valueFn func() V) (actual V, loaded bool)

+ func (m *MapOf[K, V]) LoadOrStore(key K, value V) (actual V, loaded bool)

+ func (m *MapOf[K, V]) Range(f func(key K, value V) bool)

+ func (m *MapOf[K, V]) Size() int

+ func (m *MapOf[K, V]) Store(key K, value V)

+ type RBMutex struct

+ func (m *RBMutex) Lock()

+ func (m *RBMutex) RLock() *RToken

+ func (m *RBMutex) RUnlock(t *RToken)

+ func (m *RBMutex) Unlock()

+ type RToken struct