【问题标题】:How To Assign Slices While Iterating Over a Vec in Rust without copying?如何在不复制的情况下在 Rust 中迭代 Vec 时分配切片?
【发布时间】:2016-05-18 04:17:09
【问题描述】:

我正在尝试高效地逐行解析 CSV 文件,而无需分配不必要的内存。

由于我们无法在 Rust 中对字符串进行索引,我的想法是为每一行创建一个结构体,该结构体拥有一个拥有的行字符 Vec<char> 和几个 &[char] 切片,表示该 Vec 中的位置需要进一步处理的字段。

我只支持英文,所以不需要 Unicode 字形。

我从BufReader 中抓取每一行,将其收集到我的Vec<char> 中,然后遍历字符以注意每个字段切片的正确偏移量:

let mut r_line: String;
let mut char_count: usize;
let mut comma_count: usize;
let mut payload_start: usize;
for stored in &ms7_files {
    let reader = BufReader::new(File::open(&stored.as_path()).unwrap());
    for line in reader.lines() {
        r_line = line.unwrap().to_string();
        let r_chars: Vec<char> = r_line.chars().collect();
        char_count = 0;
        comma_count = 0;
        payload_start = 0;
        for chara in r_chars {
            char_count += 1;
            if chara == ',' {
                comma_count += 1;
                if comma_count == 1 {
                    let r_itemid = &r_chars[0..char_count - 1];
                    payload_start = char_count + 1;
                } else if comma_count == 2 {
                    let r_date = &r_chars[payload_start..char_count - 1];
                    let r_payload = & r_chars[payload_start..r_line.len() - 1];
                }
            }
        }
        // Code omitted here to initialize a struct described in my
        // text above and add it to a Vec for later processing
    }
}

一切顺利,直到if 中的代码在comma_count 上测试,我尝试在Vec 中创建字符切片。当我尝试编译时,我感到很害怕:

proc_sales.rs:87:23: 87:30 error: use of moved value: `r_chars` [E0382]
proc_sales.rs:87                        let r_itemid = &r_chars[0..char_count - 1];
                                                        ^~~~~~
proc_sales.rs:87:23: 87:30 help: run `rustc --explain E0382` to see a detailed explanation
proc_sales.rs:82:17: 82:24 note: `r_chars` moved here because it has type `collections::vec::Vec<char>`, which is non-copyable
proc_sales.rs:82            for chara in r_chars {
                                     ^~~~~~~

每次尝试创建一个切片。我基本上可以理解为什么编译器会抱怨。我试图找出一种更好的策略来收集和处理这些数据,而不需要大量的复制和克隆。哎呀,如果我可以保留 BufReader 拥有的原始 String(对于每个文件行)并坚持切入其中,我会的!

欢迎对修复上述代码发表评论,并提出解决此问题的替代方法的建议,以限制不必要的复制。

【问题讨论】:

  • 我无法测试,因为我在火车上.. 但我愿意打赌,因为您的 for 循环实际上是 r_chars.into_iter().. 的语法糖,它将获得所有权。如果您改为显式使用 for chara in r_chars.iter().. 那么它将返回引用。
  • 绝对使用csv crate。 “在最低级别,解析器可以以大约 200 MB/秒的速度解码 CSV。”这需要零分配。
  • 因为我们不能在 Rust 中索引字符串,——当然可以。您只需使用位于 UTF-8 字符边界上的字节偏移量。甚至还有像 char_indices 这样的迭代器。
  • 感谢 cmets 和洞察力。 @Shepmaster,我发现解释内联代码的元文章似乎对我不起作用——当我使用 pre 和 code 标签时,预览只显示了 Vec 部分而不是其余部分。您使用的正确标记是什么?
  • @Shepmaster 感谢您提供指向 char_indexes 的链接。我正在阅读有关字符串的官方 Rust 文档,其中指出:“因为字符串是有效的 UTF-8,字符串不支持索引”,并举例说明如何尝试使用方括号语法失败。我想医生可以使用一些澄清! doc.rust-lang.org/book/strings.html#indexing

标签: csv rust slice allocation text-parsing


【解决方案1】:

BufReader::lines 返回一个生成 Result&lt;String&gt; 项的迭代器。当unwrap 在这样的项目上被调用时,它总是会分配一个新的String(注意在line.unwrap().to_string() 中,to_string() 是多余的)。

如果你想最小化分配,你可以使用BufReader::read_line

要拆分 CSV 行的字段,您可以使用 str::split

这是您的代码的简化版本:

use std::io::{BufRead, BufReader};
use std::fs::File;

fn main() {
    let mut line = String::new();
    let ms7_files = ["file1.cvs", "file2.cvs"];
    for stored in &ms7_files {
        let mut reader = BufReader::new(File::open(stored).unwrap());
        while reader.read_line(&mut line).unwrap() > 0 {
            // creates a scope to the iterator, so we can call line.clear()
            {
                // does not allocate
                let mut it = line.split(',');
                // item_id, date and payload are string slices, that is &str
                let item_id = it.next().expect("no item_id fied");
                let date = it.next().expect("no date field");
                let payload = it.next().expect("no payload field");
                // process fields
            }
            // sets len of line to 0, but does not deallocate
            line.clear()
        }
    }
}

您可能还想查看various crates 以处理 CSV 文件。

【讨论】:

  • 嘿,我真的很喜欢这个解决方案。清除已经分配的字符串完全符合我的问题的意图。我知道 str::split,但我自己只是为了试验低级处理。对于生产,我确定我会使用 split。
【解决方案2】:

对于您的问题,正如@Simon Whitehead 回答的那样,r_chars 的所有权已经转移到构建IntoIterator,因此您不能使用它。

使用修改代码

for chara in &r_chars
// equivalent to
// for chara in r_chars.iter()

只要你想(便宜)复制*chara,可能会解决它。

对于@malbarbo 的回答,如果您的csv 包含文本列(其本身可以包含换行符),我建议不要使用BufReader::lines

看看crates.io,我建议使用经过实战考验的csv,或者如果您需要稍微更高的性能但准备好使用测试较少的quick-csv

【讨论】:

  • 感谢代码修复了我最初的设计缺陷。我可以控制 CSV 布局,它不包括每条记录的换行符,所以我将采用 @malbarbo 提供的解决方案
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 2021-09-11
  • 2018-11-23
  • 1970-01-01
  • 2021-08-04
  • 1970-01-01
  • 2019-06-13
  • 1970-01-01
相关资源
最近更新 更多