messaging_thread_pool 5.0.3

A library for aiding the creation of typed thread pool of objects that is communicated with via channels
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use messaging_thread_pool::{ThreadPool, samples::*};

#[test]
pub fn example_chat_room() {
    // Create a thread pool with 2 threads
    let thread_pool = ThreadPool::<ChatRoom>::new(2);

    // Room IDs
    let room_general = 1;
    let room_tech = 2;

    // Create the rooms
    thread_pool
        .send_and_receive(vec![ChatRoomInit(room_general), ChatRoomInit(room_tech)].into_iter())
        .expect("creation requests")
        .for_each(|_| {});

    // Post messages to "General" (Room 1)
    // The pool will route these to the thread responsible for Room 1
    thread_pool
        .send_and_receive(
            vec![
                PostRequest(
                    room_general,
                    "Alice".to_string(),
                    "Hello everyone!".to_string(),
                ),
                PostRequest(room_general, "Bob".to_string(), "Hi Alice!".to_string()),
            ]
            .into_iter(),
        )
        .expect("messages to send")
        .for_each(|response| {
            // Responses are the index of the message
            assert!(response.result < 100);
        });

    // Post messages to "Tech" (Room 2)
    thread_pool
        .send_and_receive(
            vec![PostRequest(
                room_tech,
                "Charlie".to_string(),
                "Rust is cool".to_string(),
            )]
            .into_iter(),
        )
        .expect("messages to send")
        .for_each(|_| {});

    // Retrieve history from General
    let history_response = thread_pool
        .send_and_receive(vec![GetHistoryRequest(room_general)].into_iter())
        .expect("request to send")
        .next()
        .expect("response");

    let history = history_response.result;

    assert_eq!(history.len(), 2);
    assert_eq!(history[0], "Alice: Hello everyone!");
    assert_eq!(history[1], "Bob: Hi Alice!");

    // Retrieve history from Tech
    let history_response = thread_pool
        .send_and_receive(vec![GetHistoryRequest(room_tech)].into_iter())
        .expect("request to send")
        .next()
        .expect("response");

    let history = history_response.result;

    assert_eq!(history.len(), 1);
    assert_eq!(history[0], "Charlie: Rust is cool");
}