bottle 0.1.0

Actor model framework for Rust.
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
51

extern crate num_cpus;
extern crate signals;

use signals::{MutHandler, Signal, Remote, Future, SimpleScheduler, Scheduler};

struct Foo {
	n: u32
}

trait RemoteFoo {
	fn incr(&self) -> Future<u32>;
}

impl RemoteFoo for Remote<Foo> {
	fn incr(&self) -> Future<u32> {
		self.send_mut(Incr)
	}
}

struct Incr;
impl Signal for Incr {
    type Response = u32;
}

impl Foo {
    fn incr(&mut self) -> u32 {
        self.n += 1;
        self.n
    }
}

impl MutHandler<Incr> for Foo {
	fn handle_mut(&mut self, _msg: Incr) -> u32 {
		println!("incr");
		self.n += 1;
		self.n
	}
}

fn main() {
    let scheduler = SimpleScheduler::new(num_cpus::get());

	let foo = scheduler.handle(Foo { n: 0 });
	foo.incr();
	foo.incr();
	foo.incr();

	for thread in scheduler.start().drain(..) {
		thread.join();
	}
}