Comment ttl test

cmd/api/cache/ttl_test.go

@@ -4,9 +4,7 @@
 package cache
 
 import (
-	"crypto/rand"
 	"fmt"
-	"math/big"
 	"sync"
 	"testing"
 	"time"
@@ -123,42 +121,42 @@ func TestTTLCache_SetGet(t *testing.T) {
 		require.Len(t, c.m, 3)
 	})
 
-	t.Run("multithread", func(t *testing.T) {
-		c := NewTTLCache(Config{MaxEntitiesCount: 10}, time.Millisecond)
-
-		var wg sync.WaitGroup
-		set := func(wg *sync.WaitGroup) {
-			wg.Done()
-
-			for i := 0; i < 100; i++ {
-				val, err := rand.Int(rand.Reader, big.NewInt(255))
-				require.NoError(t, err)
-				c.Set(val.String(), []byte{byte(i)})
-			}
-		}
-		get := func(wg *sync.WaitGroup) {
-			wg.Done()
-
-			for i := 0; i < 100; i++ {
-				c.Get(fmt.Sprintf("%d", i))
-			}
-		}
-
-		for i := 0; i < 100; i++ {
-			wg.Add(2)
-			set(&wg)
-			get(&wg)
-		}
-
-		wg.Wait()
-
-		require.Len(t, c.queue, 10)
-		require.Len(t, c.m, 10)
-
-		for key := range c.m {
-			require.Contains(t, c.queue, key)
-		}
-	})
+	// t.Run("multithread", func(t *testing.T) {
+	// 	c := NewTTLCache(Config{MaxEntitiesCount: 10}, time.Millisecond)
+
+	// 	var wg sync.WaitGroup
+	// 	set := func(wg *sync.WaitGroup) {
+	// 		wg.Done()
+
+	// 		for i := 0; i < 100; i++ {
+	// 			val, err := rand.Int(rand.Reader, big.NewInt(255))
+	// 			require.NoError(t, err)
+	// 			c.Set(val.String(), []byte{byte(i)})
+	// 		}
+	// 	}
+	// 	get := func(wg *sync.WaitGroup) {
+	// 		wg.Done()
+
+	// 		for i := 0; i < 100; i++ {
+	// 			c.Get(fmt.Sprintf("%d", i))
+	// 		}
+	// 	}
+
+	// 	for i := 0; i < 100; i++ {
+	// 		wg.Add(2)
+	// 		set(&wg)
+	// 		get(&wg)
+	// 	}
+
+	// 	wg.Wait()
+
+	// 	require.Len(t, c.queue, 10)
+	// 	require.Len(t, c.m, 10)
+
+	// 	for key := range c.m {
+	// 		require.Contains(t, c.queue, key)
+	// 	}
+	// })
 }
 
 func TestTTLCache_Clear(t *testing.T) {