process-sync 0.2.2

Synchronization primitives for multiprocess environments
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

mod common;

use libc::fork;
use process_sync::private::check_libc_err;
pub use process_sync::private::SharedMemoryObject;

use common::{sleep, TestOutput};

fn main() {
    let mut test_output = TestOutput::new(&["123", "123", "456", "789"]);

    let mut value = SharedMemoryObject::new(123).expect("cannot create SharedMemoryObject");

    let pid = check_libc_err(unsafe { fork() }).expect("fork failed");
    if pid == 0 {
        // child
        test_output.write_line(&format!("{}", value.get()));
        sleep(20);
        *value.get_mut() = 456;
        sleep(40);
        test_output.write_line(&format!("{}", value.get()));
        std::process::exit(0);
    }

    // parent
    test_output.write_line(&format!("{}", value.get()));
    sleep(40);
    test_output.write_line(&format!("{}", value.get()));
    *value.get_mut() = 789;
    sleep(40);
}