Add concurrency test for singleton

utils/singleton/singleton_test.go

@@ -1,8 +1,12 @@
 package singleton_test
 
 import (
+	"sync"
+	"sync/atomic"
 	"testing"
 
+	"github.com/google/uuid"
+
 	"github.com/navidrome/navidrome/utils/singleton"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
@@ -14,40 +18,58 @@ func TestSingleton(t *testing.T) {
 }
 
 var _ = Describe("Get", func() {
-	type T struct{ val int }
+	type T struct{ id string }
-	var wasCalled bool
+	var numInstances int
-	var instance interface{}
 	constructor := func() interface{} {
-		wasCalled = true
+		numInstances++
-		return &T{}
+		return &T{id: uuid.NewString()}
 	}
 
-	BeforeEach(func() {
-		instance = singleton.Get(T{}, constructor)
-	})
-
 	It("calls the constructor to create a new instance", func() {
-		Expect(wasCalled).To(BeTrue())
+		instance := singleton.Get(T{}, constructor)
+		Expect(numInstances).To(Equal(1))
 		Expect(instance).To(BeAssignableToTypeOf(&T{}))
 	})
 
 	It("does not call the constructor the next time", func() {
-		instance.(*T).val = 10
+		instance := singleton.Get(T{}, constructor)
-		wasCalled = false
-
 		newInstance := singleton.Get(T{}, constructor)
 
-		Expect(newInstance.(*T).val).To(Equal(10))
+		Expect(newInstance.(*T).id).To(Equal(instance.(*T).id))
-		Expect(wasCalled).To(BeFalse())
+		Expect(numInstances).To(Equal(1))
 	})
 
 	It("does not call the constructor even if a pointer is passed as the object", func() {
-		instance.(*T).val = 20
+		instance := singleton.Get(T{}, constructor)
-		wasCalled = false
-
 		newInstance := singleton.Get(&T{}, constructor)
 
-		Expect(newInstance.(*T).val).To(Equal(20))
+		Expect(newInstance.(*T).id).To(Equal(instance.(*T).id))
-		Expect(wasCalled).To(BeFalse())
+		Expect(numInstances).To(Equal(1))
+	})
+
+	It("only calls the constructor once when called concurrently", func() {
+		const maxCalls = 2000
+		var numCalls int32
+		start := sync.WaitGroup{}
+		start.Add(1)
+		prepare := sync.WaitGroup{}
+		prepare.Add(maxCalls)
+		done := sync.WaitGroup{}
+		done.Add(maxCalls)
+		for i := 0; i < maxCalls; i++ {
+			go func() {
+				start.Wait()
+				singleton.Get(T{}, constructor)
+				atomic.AddInt32(&numCalls, 1)
+				done.Done()
+			}()
+			prepare.Done()
+		}
+		prepare.Wait()
+		start.Done()
+		done.Wait()
+
+		Expect(numCalls).To(Equal(int32(maxCalls)))
+		Expect(numInstances).To(Equal(1))
 	})
 })