Skip to content
This repository was archived by the owner on Sep 27, 2019. It is now read-only.

Commit c18a0aa

Browse files
Read the settings of threadpool correctly
1 parent 366bcf0 commit c18a0aa

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

src/include/threadpool/mono_queue_pool.h

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,9 @@ namespace threadpool {
2424
*/
2525
class MonoQueuePool {
2626
public:
27-
MonoQueuePool(int task_queue_size = 32, int worker_pool_size = 4)
27+
MonoQueuePool() = delete;
28+
29+
MonoQueuePool(int task_queue_size, int worker_pool_size)
2830
: task_queue_(task_queue_size),
2931
worker_pool_(worker_pool_size, &task_queue_),
3032
is_running_(false) {}
@@ -53,19 +55,18 @@ class MonoQueuePool {
5355
}
5456

5557
static MonoQueuePool &GetInstance() {
56-
int task_queue_size = settings::SettingsManager::GetBool(
58+
int task_queue_size = settings::SettingsManager::GetInt(
5759
settings::SettingId::monoqueue_task_queue_size);
58-
int worker_pool_size = settings::SettingsManager::GetBool(
60+
int worker_pool_size = settings::SettingsManager::GetInt(
5961
settings::SettingId::monoqueue_worker_pool_size);
60-
6162
static MonoQueuePool mono_queue_pool(task_queue_size, worker_pool_size);
6263
return mono_queue_pool;
6364
}
6465

6566
static MonoQueuePool &GetBrainInstance() {
66-
int task_queue_size = settings::SettingsManager::GetBool(
67+
int task_queue_size = settings::SettingsManager::GetInt(
6768
settings::SettingId::brain_task_queue_size);
68-
int worker_pool_size = settings::SettingsManager::GetBool(
69+
int worker_pool_size = settings::SettingsManager::GetInt(
6970
settings::SettingId::brain_worker_pool_size);
7071
static MonoQueuePool brain_queue_pool(task_queue_size, worker_pool_size);
7172
return brain_queue_pool;

test/optimizer/cost_test.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ namespace test {
4242

4343
using namespace optimizer;
4444

45-
const int N_ROW = 100;
45+
// const int N_ROW = 100;
4646

4747
class CostTests : public PelotonTest {};
4848

0 commit comments

Comments
 (0)