AsRef<Path> の thread::spawn move の方法

前提・実現したいこと

rust で AsRef<Path> の値を thread spawn で move したい。

発生している問題・エラーメッセージ

rust
1error[E0277]: `P` cannot be sent between threads safely
2  --> src/main.rs:56:5
3   |
456 |     thread::spawn(move || {
5   |     ^^^^^^^^^^^^^ `P` cannot be sent between threads safely
6   |
7   = help: within `[closure@src/main.rs:56:19: 65:6 path:P, tx:std::sync::mpsc::Sender<walkdir::DirEntry>]`, the trait `std::marker::Send` is not implemented for `P`
8   = help: consider adding a `where P: std::marker::Send` bound
9   = note: required because it appears within the type `[closure@src/main.rs:56:19: 65:6 path:P, tx:std::sync::mpsc::Sender<walkdir::DirEntry>]`
10   = note: required by `std::thread::spawn`

該当のソースコード

fn get_entries<P: AsRef<Path>>(path: P) -> mpsc::Receiver<DirEntry> {
    let (tx, rx) = mpsc::channel::<DirEntry>();
    thread::spawn(move || {
        let _ = WalkDir::new(path)
            .into_iter()
            .map(|e| match e {
                Ok(e) => tx.send(e).unwrap(),
                Err(e) => eprintln!("{}", e),
            })
            .collect::<Vec<_>>();
        drop(tx);
    });
    rx
}

path なので、文字列ではなく、 AsRef<Path> として渡したいと思っています。
rust だとこういう場合どういう風にやるのがいいのでしょうか？

thread への渡し方、後は rsut 流だとこうする、みたいなのもあれば教えて欲しいです。

rust バージョン

2018

行動規範の内容に同意します

回答2件

ベストアンサー

自分なら以下のようにメソッド内でPathBufに変換します。

rust
1use std::sync::mpsc;
2use std::thread;
3use std::path::Path;
4
5use walkdir::{DirEntry, WalkDir};
6
7fn get_entries<P: AsRef<Path>>(path: P) -> mpsc::Receiver<DirEntry> {
8    let path = path.as_ref().to_path_buf();
9    let (tx, rx) = mpsc::channel::<DirEntry>();
10    thread::spawn(move || {
11        let _ = WalkDir::new(path)
12            .into_iter()
13            .map(|e| match e {
14                Ok(e) => tx.send(e).unwrap(),
15                Err(e) => eprintln!("{}", e),
16            })
17            .collect::<Vec<_>>();
18        drop(tx);
19    });
20    rx
21}

理由として、スレッドやタスク間で値を送り合うときはownedな形式にしてしまったほうが良い (どうせspawnやsendのコストがかかる) と考えています。

別解として、以下のように P: Send + 'static を課してもコンパイルが通ります。

rust
1use std::sync::mpsc;
2use std::thread;
3use std::path::Path;
4
5use walkdir::{DirEntry, WalkDir};
6
7fn get_entries<P: AsRef<Path> + Send + 'static>(path: P) -> mpsc::Receiver<DirEntry> {
8    let (tx, rx) = mpsc::channel::<DirEntry>();
9    thread::spawn(move || {
10        let _ = WalkDir::new(path)
11            .into_iter()
12            .map(|e| match e {
13                Ok(e) => tx.send(e).unwrap(),
14                Err(e) => eprintln!("{}", e),
15            })
16            .collect::<Vec<_>>();
17        drop(tx);
18    });
19    rx
20}