utils

type Hasher ¶

type Hasher struct {
	KnownHashes map[string]uint32
	// contains filtered or unexported fields
}

Hahsher is thread-safe. If you see contention on the mutex, you may want to consider a sync.Map. Since we only write to the map once per key, and read from it many times, it might make sense.

func (h *Hasher) Hash(s string) uint32

type PriorityLock ¶

type PriorityLock interface {
	Lock()
	Unlock()
	HighPriorityLock()
	HighPriorityUnlock()
}

type PriorityPreferenceLock ¶

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

PriorityPreferenceLock implements a simple triple-mutex priority lock patterns are like:

Low Priority would do: lock lowPriorityMutex, wait for high priority groups, lock nextToAccess, lock dataMutex, unlock nextToAccess, do stuff, unlock dataMutex, unlock lowPriorityMutex
High Priority would do: increment high priority waiting, lock nextToAccess, lock dataMutex, unlock nextToAccess, do stuff, unlock dataMutex, decrement high priority waiting

func NewPriorityPreferenceLock() *PriorityPreferenceLock

func (lock *PriorityPreferenceLock) HighPriorityLock()

func (lock *PriorityPreferenceLock) HighPriorityUnlock()

func (lock *PriorityPreferenceLock) Lock()

func (lock *PriorityPreferenceLock) Unlock()