k8s deploy

internal/rpc/cache/cache.go

@@ -94,9 +94,21 @@ func SyncDB2Cache() error {
 		return utils.Wrap(err, "")
 	}
 	//err = updateAllUserToCache(userList)
-	err = updateAllFriendToCache(userList)
+	wg := &sync.WaitGroup{}
-	err = updateAllBlackListToCache(userList)
+	wg.Add(3)
-	err = updateAllGroupMemberListToCache()
+	go func() {
+		defer wg.Done()
+		err = updateAllFriendToCache(userList)
+	}()
+	go func() {
+		defer wg.Done()
+		err = updateAllBlackListToCache(userList)
+	}()
+	go func() {
+		defer wg.Done()
+		err = updateAllGroupMemberListToCache()
+	}()
+	wg.Wait()
 	return utils.Wrap(err, "")
 }