From 84cc6e9140bd57e0038d3014ddf1077d58814e01 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 24 May 2022 10:53:18 +0800 Subject: [PATCH] k8s deploy --- internal/rpc/cache/cache.go | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/internal/rpc/cache/cache.go b/internal/rpc/cache/cache.go index b8a8b2b5e..0adad4970 100644 --- a/internal/rpc/cache/cache.go +++ b/internal/rpc/cache/cache.go @@ -94,9 +94,21 @@ func SyncDB2Cache() error { return utils.Wrap(err, "") } //err = updateAllUserToCache(userList) - err = updateAllFriendToCache(userList) - err = updateAllBlackListToCache(userList) - err = updateAllGroupMemberListToCache() + wg := &sync.WaitGroup{} + wg.Add(3) + 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, "") }