qframework 0.1.2

A experimental micor framework for clear design, based on queue model
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use qframework::base::*;
use qframework::event::*;
use qframework::generator::*;
use qframework::server::*;
use qframework::queue::*;
use qframework::simulator::*;
use core::marker::PhantomData;

pub fn main()  {
    let max_sim_time = Clock::from(50);
    let capacity = 10;
    let  simulator = &mut Simulator::new();
    let  queue = &mut Queue::new();

    let  worker  = &mut Server::new();
    // the generator can be any thing have "execute()"
    let  source  = &mut Generator::new ( max_sim_time);
    let  events = &mut EventQueue::new();
    let mut ctx = Context {simulator, servers: worker, generator: source, events,queue, _marker: PhantomData };
    ctx.get_queue().capacity = capacity;

    let initial_event= Event::new(EventType::GeneratorEvent,Clock::from(0));
    ctx.get_events().insert(initial_event);

    let stats =  run(&mut ctx);
    // todo: real drop
    drop(ctx);

    println!("Send {}, processed {}, tick {} ", stats.0, stats.1, stats.2 );
}
pub fn run(ctx: &mut  Context) -> (i64,i64,i64) {
    loop {
        let event =  ctx.get_events().remove_first();
        match event {
            Some(mut e) => {
                let t = e.get_clock() ;
                ctx.get_simulator().set_clock(t);
                e.execute( ctx);
            }
            _ => {
                println!("{:?} Finished All Events",ctx.get_simulator().get_clock());

                break;
            }
        }
    }
    (ctx.get_generator().count as i64,
     ctx.get_servers().total_customers_servered as i64,
     ctx.get_simulator().get_clock().get_raw())
}