Mirror/TrinityCore
1
0
Fork 0
mirror of https://github.com/TrinityCore/TrinityCore.git synced 2026-01-16 07:30:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

Core/Threading: Create ThreadPool class

Browse Source 
(cherry picked from commit d82b2b1a67)
This commit is contained in:
Shauren
2022-10-08 20:08:29 +02:00
parent fee5160fe5
commit f59580dc6c
2 changed files with 54 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/server/worldserver/Main.cpp
View File

@@ -49,6 +49,7 @@
#include "SecretMgr.h"
#include "TCSoap.h"
#include "TerrainMgr.h"
#include "ThreadPool.h"
#include "World.h"
#include "WorldSocket.h"
#include "WorldSocketMgr.h"
@@ -248,20 +249,13 @@ extern int main(int argc, char** argv)
// Start the Boost based thread pool
int numThreads = sConfigMgr->GetIntDefault("ThreadPool", 1);
std::shared_ptr<std::vector<std::thread>> threadPool(new std::vector<std::thread>(), [ioContext](std::vector<std::thread>* del)
{
ioContext->stop();
for (std::thread& thr : *del)
thr.join();
delete del;
});
if (numThreads < 1)
numThreads = 1;
std::shared_ptr<Trinity::ThreadPool> threadPool = std::make_shared<Trinity::ThreadPool>(numThreads);
for (int i = 0; i < numThreads; ++i)
threadPool->push_back(std::thread([ioContext]() { ioContext->run(); }));
threadPool->PostWork([ioContext]() { ioContext->run(); });
// Set process priority according to configuration settings
SetProcessPriority("server.worldserver", sConfigMgr->GetIntDefault(CONFIG_PROCESSOR_AFFINITY, 0), sConfigMgr->GetBoolDefault(CONFIG_HIGH_PRIORITY, false));
@@ -406,6 +400,8 @@ extern int main(int argc, char** argv)
WorldPackets::Auth::ConnectTo::ShutdownEncryption();
WorldPackets::Auth::EnterEncryptedMode::ShutdownEncryption();
ioContext->stop();
threadPool.reset();
sLog->SetSynchronous();