Mirror/TrinityCore
1
0
Fork 0
mirror of https://github.com/TrinityCore/TrinityCore.git synced 2026-01-21 17:54:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Core/Misc: Multithread query cache loading

Browse Source
This commit is contained in:
ihm-tswow
2022-08-17 11:53:22 +02:00
committed by Shauren
parent 2c0bf1c407
commit 048089ef21
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/server/game/Globals/ObjectMgr.cpp
View File

@@ -51,6 +51,7 @@
#include "SpellScript.h"
#include "StringConvert.h"
#include "TemporarySummon.h"
#include "ThreadPool.h"
#include "UpdateMask.h"
#include "Util.h"
#include "Vehicle.h"
@@ -10386,30 +10387,34 @@ void ObjectMgr::InitializeQueriesData(QueryDataGroup mask)
return;
}
Trinity::ThreadPool pool;
// Initialize Query data for creatures
if (mask & QUERY_DATA_CREATURES)
for (auto& creatureTemplatePair : _creatureTemplateStore)
creatureTemplatePair.second.InitializeQueryData();
pool.PostWork([creature = &creatureTemplatePair.second]() { creature->InitializeQueryData(); });
// Initialize Query Data for gameobjects
if (mask & QUERY_DATA_GAMEOBJECTS)
for (auto& gameObjectTemplatePair : _gameObjectTemplateStore)
gameObjectTemplatePair.second.InitializeQueryData();
pool.PostWork([gobj = &gameObjectTemplatePair.second]() { gobj->InitializeQueryData(); });
// Initialize Query Data for items
if (mask & QUERY_DATA_ITEMS)
for (auto& itemTemplatePair : _itemTemplateStore)
itemTemplatePair.second.InitializeQueryData();
pool.PostWork([item = &itemTemplatePair.second]() { item->InitializeQueryData(); });
// Initialize Query Data for quests
if (mask & QUERY_DATA_QUESTS)
for (auto& questTemplatePair : _questTemplates)
questTemplatePair.second.InitializeQueryData();
pool.PostWork([quest = &questTemplatePair.second]() { quest->InitializeQueryData(); });
// Initialize Quest POI data
if (mask & QUERY_DATA_POIS)
for (auto& poiWrapperPair : _questPOIStore)
poiWrapperPair.second.InitializeQueryData();
pool.PostWork([poi = &poiWrapperPair.second]() { poi->InitializeQueryData(); });
pool.Join();
TC_LOG_INFO("server.loading", ">> Initialized query cache data in %u ms", GetMSTimeDiffToNow(oldMSTime));
}