From 7c0bbd3f6a3ed9a8e5b879a00dbd4dad88e375c3 Mon Sep 17 00:00:00 2001 From: kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com> Date: Tue, 8 Nov 2022 09:35:01 +0000 Subject: [chore] update gruf libraries (#996) * update go-store to v2.0.6: closer callbacks are now only ever called at most once Signed-off-by: kim * bump go-store => v2.0.7, go-mutexes => v1.1.4 Signed-off-by: kim Signed-off-by: kim --- vendor/codeberg.org/gruf/go-mutexes/map_pool.go | 39 +++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 vendor/codeberg.org/gruf/go-mutexes/map_pool.go (limited to 'vendor/codeberg.org/gruf/go-mutexes/map_pool.go') diff --git a/vendor/codeberg.org/gruf/go-mutexes/map_pool.go b/vendor/codeberg.org/gruf/go-mutexes/map_pool.go new file mode 100644 index 000000000..450e0bc06 --- /dev/null +++ b/vendor/codeberg.org/gruf/go-mutexes/map_pool.go @@ -0,0 +1,39 @@ +package mutexes + +// pool is a very simply memory pool. +type pool struct { + current []*rwmutex + victim []*rwmutex +} + +// Acquire will returns a rwmutex from pool (or alloc new). +func (p *pool) Acquire() *rwmutex { + // First try the current queue + if l := len(p.current) - 1; l >= 0 { + mu := p.current[l] + p.current = p.current[:l] + return mu + } + + // Next try the victim queue. + if l := len(p.victim) - 1; l >= 0 { + mu := p.victim[l] + p.victim = p.victim[:l] + return mu + } + + // Lastly, alloc new. + return &rwmutex{} +} + +// Release places a sync.RWMutex back in the pool. +func (p *pool) Release(mu *rwmutex) { + p.current = append(p.current, mu) +} + +// GC will clear out unused entries from the pool. +func (p *pool) GC() { + current := p.current + p.current = nil + p.victim = current +} -- cgit v1.2.3