Multithreaded Logger Demo (Rust)

main.rs

use log::info;
use std::env;
use std::sync::mpsc;
use std::sync::mpsc::Sender;
use std::thread;

fn init_log() {
    env::set_var("RUST_LOG", "info");
    env_logger::builder()
        .default_format()
        .format_timestamp_nanos()
        .format_indent(Some(4))
        .init();
}

fn log_info(sender: &Sender<String>, message: String) {
    let _ = sender.send(message);
}

fn main() {
    init_log();
    let (sender, receiver) = mpsc::channel();
    let logger_thread = thread::spawn(move || loop {
        match receiver.recv() {
            Ok(log_message) => info!("{}", log_message),
            Err(_) => break,
        }
    });
    // Sender move & drop semantic
    {
        let moved_sender = sender;

        for i in 0..100_000 {
            log_info(&moved_sender, format!("Hello this is {}", i));
        }
    }
    let _ = logger_thread.join();
}