vendor/jpeg-decoder/tests/rayon-2.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Must be a separate test because it modifies the _global_ rayon pool.
use std::{fs::File, path::Path};
use jpeg_decoder::Decoder;

#[test]
fn decoding_in_global_pool() {
    let path = Path::new("tests/reftest/images/progressive3.jpg");

    rayon::ThreadPoolBuilder::new()
        .num_threads(2)
        .build_global()
        .unwrap();

    let _: Vec<_> = (0..1024)
        .map(|_| {
            let path = path.clone();
            std::thread::spawn(move || {
                let mut decoder = Decoder::new(File::open(&path).unwrap());
                let _ = decoder.decode().unwrap();
            });
        }).collect();
}