generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-10-23 16:48:06 +02:00
Code Issues Projects Releases Wiki Activity

Refinement to ThreadPool::addCapacity() usage in TCPServer

Browse Source
This commit is contained in:
karlr42
2014-03-07 12:22:27 +00:00
parent b509b7e91a
commit bf29f72cdf
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Net/src/TCPServer.cpp
View File

@@ -57,9 +57,7 @@ TCPServer::TCPServer(TCPServerConnectionFactory::Ptr pFactory, Poco::UInt16 port
{ {
Poco::ThreadPool& pool = Poco::ThreadPool::defaultPool(); Poco::ThreadPool& pool = Poco::ThreadPool::defaultPool();
if(pParams && (pParams->getMaxThreads() > pool.capacity())){ if(pParams) pool.addCapacity(pParams->getMaxThreads() - pool.capacity());
pool.addCapacity(pParams->getMaxThreads());
}
_pDispatcher = new TCPServerDispatcher(pFactory, pool, pParams); _pDispatcher = new TCPServerDispatcher(pFactory, pool, pParams);
} }
@@ -71,9 +69,7 @@ TCPServer::TCPServer(TCPServerConnectionFactory::Ptr pFactory, const ServerSocke
_stopped(true) _stopped(true)
{ {
Poco::ThreadPool& pool = Poco::ThreadPool::defaultPool(); Poco::ThreadPool& pool = Poco::ThreadPool::defaultPool();
if(pParams && (pParams->getMaxThreads() > pool.capacity())){ if(pParams) pool.addCapacity(pParams->getMaxThreads() - pool.capacity());
pool.addCapacity(pParams->getMaxThreads());
}
_pDispatcher = new TCPServerDispatcher(pFactory, pool, pParams); _pDispatcher = new TCPServerDispatcher(pFactory, pool, pParams);
} }