Function TestCache_Memory

internal/ttlcache/cache_test.go:47–95

(t *testing.T)

}

func TestCache_Memory(t *testing.T) {
	if !testutils.IsSingleTesting() {
		return
	}

	var cache = NewCache[int]()
	var isReady bool

	testutils.StartMemoryStats(t, func() {
		if !isReady {
			return
		}
		t.Log(cache.Count(), "items")
	})

	var count = 1_000_000
	if memutils.SystemMemoryGB() > 4 {
		count = 20_000_000
	}
	for i := 0; i < count; i++ {
		cache.Write("a"+strconv.Itoa(i), 1, time.Now().Unix()+int64(rands.Int(0, 300)))
	}

	func() {
		var before = time.Now()
		runtime.GC()
		var costSeconds = time.Since(before).Seconds()
		var stats = &debug.GCStats{}
		debug.ReadGCStats(stats)
		t.Log("GC pause:", stats.Pause[0].Seconds()*1000, "ms", "cost:", costSeconds*1000, "ms")
	}()

	isReady = true

	t.Log(cache.Count())

	time.Sleep(10 * time.Second)
	for i := 0; i < count; i++ {
		if i%2 == 0 {
			cache.Delete("a" + strconv.Itoa(i))
		}
	}

	t.Log(cache.Count())

	cache.Count()

	time.Sleep(3600 * time.Second)
}

func TestCache_IncreaseInt64(t *testing.T) {
	var a = assert.NewAssertion(t)