syncedlru_test.go

// nolint: dupl
package freelru

import (
	"sync"
	"testing"
)

// TestSyncedRaceCondition tests that the synced LRU is safe to use concurrently.
// Test with 'go test . -race'.
func TestSyncedRaceCondition(t *testing.T) {
	const CAP = 4

	lru, err := NewSynced[uint64, int](CAP, hashUint64)
	if err != nil {
		t.Fatalf("err: %v", err)
	}

	wg := sync.WaitGroup{}

	call := func(fn func()) {
		wg.Add(1)
		go func() {
			fn()
			wg.Done()
		}()
	}

	call(func() { lru.SetLifetime(1) })
	call(func() { lru.SetOnEvict(nil) })
	call(func() { _ = lru.Len() })
	call(func() { _ = lru.AddWithLifetime(1, 1, 0) })
	call(func() { _ = lru.Add(1, 1) })
	call(func() { _, _ = lru.Get(1) })
	call(func() { _, _ = lru.GetAndRefresh(1) })
	call(func() { _, _ = lru.Peek(1) })
	call(func() { _ = lru.Contains(1) })
	call(func() { _ = lru.Remove(1) })
	call(func() { _, _, _ = lru.RemoveOldest() })
	call(func() { _ = lru.Keys() })
	call(func() { lru.Purge() })
	call(func() { lru.PurgeExpired() })
	call(func() { lru.Metrics() })
	call(func() { _ = lru.ResetMetrics() })
	call(func() { lru.dump() })
	call(func() { lru.PrintStats() })

	wg.Wait()
}

func TestSyncedLRUMetrics(t *testing.T) {
	cache, _ := NewSynced[uint64, uint64](1, hashUint64)
	testMetrics(t, cache)
}