add config

Author: zhuxiujia

src/config.rs

@@ -33,6 +33,8 @@ pub struct Config {
     pub format: Box<dyn RecordFormat>,
     /// the channel length,default None(Unbounded channel)
     pub chan_len: Option<usize>,
+    /// number of worker threads that receive and dispatch log records from the main channel to appenders
+    pub worker_tasks: Option<usize>,
 }
 
 impl Debug for Config {
@@ -53,6 +55,7 @@ impl Default for Config {
             filters: SyncVec::new(),
             format: Box::new(FastLogFormat::new()),
             chan_len: None,
+            worker_tasks: Some(1),
         }
     }
 }
@@ -192,4 +195,10 @@ impl Config {
         self.chan_len = len;
         self
     }
+
+    /// set the number of worker threads, default is 1
+    pub fn worker_tasks(mut self, num: Option<usize>) -> Self {
+        self.worker_tasks = num;
+        self
+    }
 }

src/fast_log.rs

@@ -174,7 +174,8 @@ pub fn init(config: Config) -> Result<&'static Logger, LogError> {
         });
     }
     let sender_vec = Arc::new(sender_vec);
-    for _ in 0..1 {
+    let thread_num = cfg.worker_tasks.unwrap_or(1);
+    for _ in 0..thread_num {
         let senders = sender_vec.clone();
         spawn(move || {
             loop {