interthread 3.1.0

Auto implementation of the Actor 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
51



use std::sync::{Arc,RwLock};

pub struct Actor {
    value: u16,
}

#[interthread::family( show,
    actor( first_name = "User" ,show, include(increment,method)),
    actor( first_name = "Admin" ,show, include(get_value)),
)] 

impl Actor {

  pub fn new( v: u16 ) -> Self {
     Self { value: v } 
  }
  pub fn increment(&mut self) {
      std::thread::sleep(std::time::Duration::from_millis(10));
      self.value += 1;
  }
  pub fn get_value(&self) -> u16 {
      self.value
  }
  
  pub fn method(actor: &Arc<RwLock<Self>>, s: u16) -> u16 {
    let _actor = actor.read().unwrap();
    // some operations 
    s
  }

}

//  #[interthread::example(main,path="examples/intro_family.rs")] 
fn main() {

    let family = ActorFamily::new(0);

    let ActorFamily { mut user, admin } = family ;

    let _ = std::thread::spawn( move || { 

        for _ in 0..100 { user.increment(); }

    }).join(); 

    // after all the messages are sent
    // we access the actor via `admin`
    println!("processed messages = {}",admin.get_value());
}