@@ -24,9 +24,7 @@ namespace threadpool {
24
24
*/
25
25
class MonoQueuePool {
26
26
public:
27
- MonoQueuePool () = delete ;
28
-
29
- MonoQueuePool (int task_queue_size, int worker_pool_size)
27
+ MonoQueuePool (uint32_t task_queue_size, uint32_t worker_pool_size)
30
28
: task_queue_(task_queue_size),
31
29
worker_pool_ (worker_pool_size, &task_queue_),
32
30
is_running_(false ) {}
@@ -55,18 +53,18 @@ class MonoQueuePool {
55
53
}
56
54
57
55
static MonoQueuePool &GetInstance () {
58
- int task_queue_size = settings::SettingsManager::GetInt (
56
+ uint32_t task_queue_size = settings::SettingsManager::GetInt (
59
57
settings::SettingId::monoqueue_task_queue_size);
60
- int worker_pool_size = settings::SettingsManager::GetInt (
58
+ uint32_t worker_pool_size = settings::SettingsManager::GetInt (
61
59
settings::SettingId::monoqueue_worker_pool_size);
62
60
static MonoQueuePool mono_queue_pool (task_queue_size, worker_pool_size);
63
61
return mono_queue_pool;
64
62
}
65
63
66
64
static MonoQueuePool &GetBrainInstance () {
67
- int task_queue_size = settings::SettingsManager::GetInt (
65
+ uint32_t task_queue_size = settings::SettingsManager::GetInt (
68
66
settings::SettingId::brain_task_queue_size);
69
- int worker_pool_size = settings::SettingsManager::GetInt (
67
+ uint32_t worker_pool_size = settings::SettingsManager::GetInt (
70
68
settings::SettingId::brain_worker_pool_size);
71
69
static MonoQueuePool brain_queue_pool (task_queue_size, worker_pool_size);
72
70
return brain_queue_pool;
0 commit comments