27 lines
670 B
Rust
27 lines
670 B
Rust
|
//! Show how to use an `FFT` object from multiple threads
|
||
|
|
|
||
|
|
use std::sync::Arc;
|
||
|
|
use std::thread;
|
||
|
|
|
||
|
|
use rustfft::num_complex::Complex32;
|
||
|
|
use rustfft::FftPlanner;
|
||
|
|
|
||
|
|
fn main() {
|
||
|
|
let mut planner = FftPlanner::new();
|
||
|
|
let fft = planner.plan_fft_forward(100);
|
||
|
|
|
||
|
|
let threads: Vec<thread::JoinHandle<_>> = (0..2)
|
||
|
|
.map(|_| {
|
||
|
|
let fft_copy = Arc::clone(&fft);
|
||
|
|
thread::spawn(move || {
|
||
|
|
let mut buffer = vec![Complex32::new(0.0, 0.0); 100];
|
||
|
|
fft_copy.process(&mut buffer);
|
||
|
|
})
|
||
|
|
})
|
||
|
|
.collect();
|
||
|
|
|
||
|
|
for thread in threads {
|
||
|
|
thread.join().unwrap();
|
||
|
|
}
|
||
|
|
}
|