database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-30 19:23:07 +03:00
Code Activity

MCOL-513 Use threadpool for session threads

Browse Source
This commit is contained in:
David Hall
2017-01-24 16:27:11 -06:00
parent edd8a30142
commit 892906d40b
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
exemgr/main.cpp
View File

@ -97,6 +97,8 @@ using namespace querytele;
#include "utils_utf8.h" #include "utils_utf8.h"
#include "boost/filesystem.hpp" #include "boost/filesystem.hpp"
#include "threadpool.h"
namespace { namespace {
//If any flags other than the table mode flags are set, produce output to screeen //If any flags other than the table mode flags are set, produce output to screeen
@ -1431,12 +1433,14 @@ int main(int argc, char* argv[])
} }
} }
threadpool::ThreadPool exeMgrThreadPool(serverThreads, serverQueueSize);
for (;;) for (;;)
{ {
IOSocket ios; IOSocket ios;
ios = mqs->accept(); ios = mqs->accept();
boost::thread thd(SessionThread(ios, ec, rm)); exeMgrThreadPool.invoke(SessionThread(ios, ec, rm));
} }
exeMgrThreadPool.wait();
return 0; return 0;
} }