有没有办法直接消耗Rayon链而不先收集它？

Question

我正在使用 Rayon 产生相当大的返回值。将所有返回值收集到Vec. 有没有办法避免创建 aVec并直接将其作为可迭代对象使用？

这是一个不起作用的例子：

fn main() {
    let numbers: Vec<_> = "12.03 0.3 44.2 45 zzz".split_whitespace().collect();

    let x = numbers
        .par_iter()
        .map(|n| n.parse::<f32>())
        .filter_map(|n| n.ok());

    for n in x {
        println!("{:?}", n);
    }
}

fn main() {
    let numbers: Vec<_> = "12.03 0.3 44.2 45 zzz".split_whitespace().collect();

    let x = numbers
        .par_iter()
        .map(|n| n.parse::<f32>())
        .filter_map(|n| n.ok());

    for n in x {
        println!("{:?}", n);
    }
}

操场

Answer 1

您正在寻找ParallelIterator::for_each：

extern crate rayon; // 1.0.2

use rayon::prelude::*;

fn main() {
    let numbers = ["12.03", "0.3", "44.2", "45", "zzz"];

    let x = numbers.par_iter().flat_map(|n| n.parse::<f32>());

    x.for_each(|n| {
        println!("{:?}", n);
    });
}

有关的：

• ParallelIterator::for_each_with
• ParallelIterator::try_for_each
• ParallelIterator::try_for_each_with

也可以看看：

• 为了在这里使用 Rayon，如何满足 Iterator trait bound？