use sync chan

Signed-off-by: sivchari <shibuuuu5@gmail.com>
kubernetes-sigs · Sep 24, 2024 · a832abf · a832abf
1 parent 96ae64f
commit a832abf
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/test/infrastructure/inmemory/pkg/runtime/cache/sync.go b/test/infrastructure/inmemory/pkg/runtime/cache/sync.go
@@ -50,8 +50,10 @@ func (c *cache) startSyncer(ctx context.Context) error {
 		c.syncQueue.ShutDown()
 	}()
 
+	syncLoopStarted := make(chan struct{})
 	go func() {
 		log.Info("Starting sync loop")
+		syncLoopStarted <- struct{}{}
 		for {
 			select {
 			case <-time.After(c.syncPeriod / 4):
@@ -79,6 +81,8 @@ func (c *cache) startSyncer(ctx context.Context) error {
 		wg.Wait()
 	}()
 
+	<-syncLoopStarted
+
 	if err := wait.PollUntilContextTimeout(ctx, 50*time.Millisecond, 5*time.Second, false, func(context.Context) (done bool, err error) {
 		if atomic.LoadInt64(&workers) < int64(c.syncConcurrency) {
 			return false, nil