sealrs 0.13.2

Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
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 crate::actors::prelude::*;
use crate::examples::actors::basic::basic_actor;
use super::my_dispatcher::MyDispatcher;
use std::sync::{Mutex, Arc};
use std::thread;
use std::time::Duration;

struct OtherMsg {}

pub fn run() {
    // This example demonstrates how you may implement your own dispatcher. MyDispatcher is the
    // simplified clone of the DefaultDispatcher, which contain logging of every stage of him work.
    // This dispatcher is added to the actor system and on him will runs the basic_actor from
    // the basic example. This example work in a similar way as the basic example, but this adds
    // some additional operations, for demonstrate, how dispatcher is reacts to them.

    // Creating new dispatcher instance
    let my_dispatcher = MyDispatcher::new(1);


    let mut system = LocalActorSystem::new();

    // Registration of the early created dispatcher in the actor system
    system.add_dispatcher("my-dispatcher", tsafe!(my_dispatcher));

    // Creating the actor with the custom dispatcher
    let custom_props = Props::new(tsafe!(basic_actor::BasicActor::new()))
        .with_dispatcher("my-dispatcher");

    let mut printer = system.actor_of(custom_props, None);

    // Sends the message which will be handled
    let msg = msg!(basic_actor::Print { text: String::from("Hello world!") });
    printer.tell(msg, None);

    // Sends the message which will does't be handled
    let msg = msg!(OtherMsg {});
    printer.tell(msg, None);

    thread::sleep(Duration::from_secs(1));

    // Stops the actor
    system.stop(&mut printer);

    thread::sleep(Duration::from_secs(1));

    // Terminate the actor system
    system.terminate();

    thread::park();
}