Function TestSyncMapAddDelete

pkg/cache/syncmap_test.go:43–74

(t *testing.T)

}

func TestSyncMapAddDelete(t *testing.T) {
	sm := NewSyncMap(10)
	var wg sync.WaitGroup

	addEntry := func(key string, value int) {
		sm.Set(key, value)
		wg.Done()
	}

	deleteEntry := func(key string) {
		sm.Delete(key)
		wg.Done()
	}

	wg.Add(10)
	for i := 0; i < 10; i++ {
		go addEntry(fmt.Sprintf("%d", i), i)
	}

	wg.Wait()

	wg.Add(10)
	for i := 0; i < 10; i++ {
		go deleteEntry(fmt.Sprintf("%d", i))
	}

	wg.Wait()
	mapLen := len(*sm.mapObj)
	if mapLen != 0 {
		t.Fatalf("unexpected length of map: %d", mapLen)
	}
}

func TestSyncMapUpdate(t *testing.T) {
	sm := NewSyncMap(10)