add concurrent delete test

Author: AxelPrel

cache_test.go

@@ -2,7 +2,9 @@ package cache_test
 
 import (
 	"math/rand"
+	"strconv"
 	"sync"
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -121,3 +123,38 @@ func TestCallJanitor(t *testing.T) {
 		t.Errorf("want items is empty but got %d", len(keys))
 	}
 }
+
+func TestConcurrentDelete(t *testing.T) {
+	c := cache.New[string, int]()
+	exp := 5 * time.Second
+	for k := 1; k <= 10; k++ {
+		c.Set(strconv.Itoa(k), k, cache.WithExpiration(exp))
+	}
+	var (
+		wg   sync.WaitGroup
+		stop atomic.Bool
+	)
+
+	time.AfterFunc(10*time.Second, func() {
+		stop.Store(true)
+	})
+
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		for k := 1; !stop.Load(); k++ {
+			c.Set(strconv.Itoa(k), k, cache.WithExpiration(0))
+			c.Delete(strconv.Itoa(k))
+		}
+	}()
+
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		for !stop.Load() {
+			c.DeleteExpired()
+		}
+	}()
+
+	wg.Wait()
+}