Limit tagreader workers to 2

This commit is contained in:
Jonas Kvinge 2019-10-19 15:09:18 +02:00
parent e76ddd6dd2
commit cf5198ac64
2 changed files with 4 additions and 1 deletions

View File

@ -158,11 +158,13 @@ WorkerPool<HandlerType>::WorkerPool(QObject *parent)
: _WorkerPoolBase(parent), : _WorkerPoolBase(parent),
next_worker_(0), next_worker_(0),
next_id_(0) { next_id_(0) {
worker_count_ = qBound(1, QThread::idealThreadCount() / 2, 2); worker_count_ = qBound(1, QThread::idealThreadCount() / 2, 2);
local_server_name_ = qApp->applicationName().toLower(); local_server_name_ = qApp->applicationName().toLower();
if (local_server_name_.isEmpty()) if (local_server_name_.isEmpty())
local_server_name_ = "workerpool"; local_server_name_ = "workerpool";
} }
template <typename HandlerType> template <typename HandlerType>

View File

@ -46,8 +46,9 @@ TagReaderClient::TagReaderClient(QObject *parent) : QObject(parent), worker_pool
original_thread_ = thread(); original_thread_ = thread();
worker_pool_->SetExecutableName(kWorkerExecutableName); worker_pool_->SetExecutableName(kWorkerExecutableName);
worker_pool_->SetWorkerCount(QThread::idealThreadCount()); worker_pool_->SetWorkerCount(qBound(1, QThread::idealThreadCount() / 2, 2));
connect(worker_pool_, SIGNAL(WorkerFailedToStart()), SLOT(WorkerFailedToStart())); connect(worker_pool_, SIGNAL(WorkerFailedToStart()), SLOT(WorkerFailedToStart()));
} }
void TagReaderClient::Start() { worker_pool_->Start(); } void TagReaderClient::Start() { worker_pool_->Start(); }