Add config task.exec_workers and task.exec_queue_max

rmqtt.toml

@@ -2,6 +2,14 @@
 ## General
 ##--------------------------------------------------------------------
 
+##--------------------------------------------------------------------
+## Task
+##--------------------------------------------------------------------
+#Concurrent task count for global task executor.
+task.exec_workers = 1000
+#Queue capacity for global task executor.
+task.exec_queue_max = 300_000
+
 ##--------------------------------------------------------------------
 ## Node
 ##--------------------------------------------------------------------

rmqtt/src/runtime.rs

@@ -30,15 +30,20 @@ static INSTANCE: OnceCell<Runtime> = OnceCell::new();
 impl Runtime {
     #[inline]
     pub async fn init() -> &'static Self {
-        let (exec, task_runner) = Builder::default().workers(100).queue_max(100_000).build();
+        let settings = Settings::instance();
+
+        let (exec, task_runner) = Builder::default()
+            .workers(settings.task.exec_workers)
+            .queue_max(settings.task.exec_queue_max)
+            .build();
+
         spawn(async move {
             task_runner.await;
         });
 
         let sched = JobScheduler::new().await.unwrap();
         sched.start().await.unwrap();
 
-        let settings = Settings::instance();
         let r = Self {
             logger: config_logger(settings.log.filename(), settings.log.to, settings.log.level),
             settings: settings.clone(),

rmqtt/src/settings/mod.rs

@@ -30,6 +30,8 @@ pub struct Settings(Arc<Inner>);
 
 #[derive(Debug, Clone, Deserialize)]
 pub struct Inner {
+    #[serde(default)]
+    pub task: Task,
     #[serde(default)]
     pub node: Node,
     #[serde(default)]
@@ -128,6 +130,23 @@ impl fmt::Debug for Settings {
     }
 }
 
+#[derive(Default, Debug, Clone, Deserialize)]
+pub struct Task {
+    #[serde(default = "Task::exec_workers_default")]
+    pub exec_workers: usize,
+    #[serde(default = "Task::exec_queue_max_default")]
+    pub exec_queue_max: usize,
+}
+
+impl Task {
+    fn exec_workers_default() -> usize {
+        1000
+    }
+    fn exec_queue_max_default() -> usize {
+        300_000
+    }
+}
+
 #[derive(Default, Debug, Clone, Deserialize)]
 pub struct Node {
     #[serde(default)]