Event loop in Rust using Tokio, futures, and mpsc channels.

main.rs

type Closure = Box<Fn() + Send>;

fn main() {
    let (tx, rx) = std::sync::mpsc::channel::<Closure>();
    let eventloop = futures::future::lazy(move || {
        loop {
            if let Ok(call) = rx.recv() {
                tokio::spawn(futures::future::lazy(move || {
                    call();
                    futures::future::ok::<(), ()>(())
                }));
            }
        }
        futures::future::ok::<(), ()>(())
    });
    std::thread::spawn(move || {
        let mut count: i32 = 0;
        loop {
            tx.send(Box::new(||{
                println!("Hello world!");
            })).unwrap();
            count += 1;
            if count >= 5 {
                break;
            } else {
                std::thread::sleep(std::time::Duration::new(5, 0));
            }
        }
    });
    // Start the event loop
    tokio::run(eventloop);
}