crossbeam 0.2.5

Support for lock-free data structures, synchronizers, and parallel programming
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

use std::thread;
use std::process::{self, Command};
use std::io::prelude::*;

fn one_loop() {
    loop {
        // let res = Command::new("cargo")
        //               .arg("test")
        //               .arg("ms_queue::test::push_try_pop_many_spmc")
        //               .arg("--release")
        //               .status()
        //               .unwrap()
        //               .success();
        let res = Command::new("target/release/stress-msq2")
                      .status()
                      .unwrap();
        if !res.success() {
            println!("Bad exit: {:?}", res);
            std::io::stdout().flush();
            process::exit(1);
        }
    }
}

fn main() {
    println!("Slamming...");
    for _i in 0..3 {
        thread::spawn(one_loop);
    }
    one_loop();
}