hirun 0.1.16

A concurrent framework for asynchronous programming based on event-driven, non-blocking I/O mechanism
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use core::cell::Cell;
use hicollections::{list, List, ListNode};
use super::Scheduler;

#[repr(C)]
pub struct Event {
    pub(crate) node: ListNode,
    // 接收到的事件
    pub(crate) events: Cell<u32>,
    handle: fn(&Event, u32, &mut Scheduler),
}

pub fn event_list_new() -> List<Event> {
    list!(Event, node)
}

impl Event {
    pub fn new(handle: fn(&Event, u32, &mut Scheduler)) -> Self {
        Self {
            node: ListNode::new(),
            events: Cell::new(0),
            handle,
        }
    }

    pub fn handle(&self, event: u32, sched: &mut Scheduler) {
        (self.handle)(self, event, sched)
    }
}