looper

基于rust实现的消息事件循环系统。

• looper模块负责用户消息的插入；
• handler模块负责处理用户消息；

基本原理

looper模块将用户的所有消息，按照UNIX时间顺序，插入到链表中； handler模块从链表中，取出已经到时间的消息进行处理。

示例

use rooper::{Looper, LooperMsg};

struct ExMsg {
    val: i32,
}

impl LooperMsg for ExMsg {
    fn handle_message(self) {
        println!("msg val: {}", self.val);
    }
}

fn main() {
    let mut lp = Looper::new();
    lp.send_msg_delay(ExMsg {val: 4}, std::time::Duration::from_millis(400));
    lp.send_msg_delay(ExMsg {val: 3}, std::time::Duration::from_millis(600));
    lp.send_msg_delay(ExMsg {val: 2}, std::time::Duration::from_millis(800));
    lp.send_msg_delay(ExMsg {val: 1}, std::time::Duration::from_millis(1000));
    lp.send_msg_delay(ExMsg {val: 5}, std::time::Duration::from_millis(200));

    std::thread::sleep(std::time::Duration::from_secs(2));
    lp.terminate();
}