有没有一种方法可以检测到人造丝中的溢出,并迫使它陷入恐慌,而不是出现无限循环?
extern crate rayon;
use rayon::prelude::*;
fn main() {
let sample: Vec<u32> = (0..50000000).collect();
let sum: u32 = sample.par_iter().sum();
println!("{}",sum );
}发布于 2018-07-29 03:45:05
您正在寻找ParallelIterator::try_reduce。文档示例实现了您想要的功能(甚至更多):
使用rayon::prelude::*;//计算平方和,小心溢出。fn sum_squares>(iter: I) -> Option { iter.into_par_iter() .map(|i| i.checked_mul(i)) //每一项,.try_reduce(|| 0,i32::checked_add) //并相加!} assert_eq!(sum_squares(0..5),Some(0 +1+4+9+ 16));//求和可能溢出assert_eq!(sum_squares(0..10_000),None);//或者平方甚至在到达
try\_reduceassert_eq之前就溢出!(sum_squares(1_000_000..1_000_001),None);
特别针对您的示例:
extern crate rayon;
use rayon::prelude::*;
fn main() {
let sample: Vec<u32> = (0..50000000).collect();
let sum = sample
.into_par_iter()
.map(Some)
.try_reduce(
|| 0,
|a, b| a.checked_add(b)
);
println!("{:?}", sum);
}collect是不必要的低效的,但我暂时不去管它。
https://stackoverflow.com/questions/51574380
复制相似问题