dev-stress 0.9.4

High-load stress and soak testing for Rust. Concurrent workloads, latency percentiles, throughput collapse detection, sustained-pressure verdicts. Part of the dev-* verification collection.
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

//! Define a `Workload`, run it under multi-threaded stress, print results.
//!
//! ```text
//! cargo run --example workload --release
//! ```
//!
//! Demonstrates the `Workload` trait + `StressRun::execute` flow. The
//! workload is intentionally trivial; replace `run_once` with the code
//! under test to measure real throughput, contention, and per-thread CV.

use dev_stress::{StressRun, Workload};

#[derive(Clone)]
struct TrivialAdd;

impl Workload for TrivialAdd {
    fn run_once(&self) {
        let mut acc: u64 = 0;
        for i in 0..100 {
            acc = std::hint::black_box(acc.wrapping_add(i));
        }
        std::hint::black_box(acc);
    }
}

fn main() {
    let run = StressRun::new("trivial_add").iterations(100_000).threads(4);

    println!(
        "configured: {} iterations across {} threads",
        run.iterations_planned(),
        run.threads_planned()
    );

    let result = run.execute(&TrivialAdd);

    println!("name:           {}", result.name);
    println!("iterations:     {}", result.iterations);
    println!("threads:        {}", result.threads);
    println!("total_elapsed:  {:?}", result.total_elapsed);
    println!("ops_per_sec:    {:.0}", result.ops_per_sec());
    println!("thread_time_cv: {:.4}", result.thread_time_cv());
}