はじめに
#NO IMAGEThe Rust Programming Language 日本語版 - The Rust Programming Language 日本語版
を読んでいる
お勉強
#- メッセージの受け渡しらしい
- あんまりわかっていない
- ポーリングとかキューイング的なイメージだろうか
NO IMAGEメッセージ受け渡しを使ってスレッド間でデータを転送する - The Rust Programming Language 日本語版
- ざっくり読む
メモ
#- んー光らせたが
- チャンネルという概念と受信機、転送機の話っぽい
- 合っているかも
チャンネルは、あるスレッドから別のスレッドへデータを送信する手段である、普遍的なプログラミング概念です。
- あってそうだな
- マイクロサービスのふわっとした概念と同じかもね
- チャンネルに転送受信機がある
- どっちかがドロップしたら終了
use std::sync::mpsc;
fn main() {
let (tx, rx) = mpsc::channel();
}
- チャンネルはこうやって作るらしい
- なるほど、セットで生成するんだな
- でもこれはコンパイルできない
let文でパターンを使用することと分配については、第18章で議論しましょう。
- 前から出てきた気がするけどな
転送機には、送信したい値を取る
sendメソッドがあります。sendメソッドはResult<T, E>型を返すので、 既に受信機がドロップされ、値を送信する場所がなければ、送信処理はエラーを返します。
- うおーここでも
Result使うのか- rust書く時にめちゃくちゃ重要だな
use std::sync::mpsc;
use std::thread;
fn main() {
let (tx, rx) = mpsc::channel();
thread::spawn(move || {
let val = String::from("hi");
tx.send(val).unwrap();
});
let received = rx.recv().unwrap();
// "取得しました: {}"
println!("Got: {}", received);
}
- はいはい、なるほど
- さすがにこれは説明読まなくて分かるな
rx.recvで返ってくんだな- んあ？これ、どの型が返ってくるか不明だから型推論しないとだめだな
- この辺でトラブりそう
メッセージを待つこと以外にメインスレッドがすべき作業はないので、 メインスレッドをブロックするのは適切です。
- ブロックするという概念ね
use std::sync::mpsc;
use std::thread;
fn main() {
let (tx, rx) = mpsc::channel();
thread::spawn(move || {
let val = String::from("hi");
tx.send(val).unwrap();
// "valは{}です"
println!("val is {}", val);
});
let received = rx.recv().unwrap();
println!("Got: {}", received);
}
$ cargo run
Compiling message-passing v0.1.0 (file:///projects/message-passing)
error[E0382]: borrow of moved value: `val`
(エラー: ムーブされた値の借用: `val`)
--> src/main.rs:10:31
|
8 | let val = String::from("hi");
| --- move occurs because `val` has type `String`, which does not implement the `Copy` trait
| (`val`は`Copy`トレイトを実装しない`String`型を持つので、ムーブが発生します)
9 | tx.send(val).unwrap();
| --- value moved here
| (値はここでムーブされます)
10 | println!("val is {}", val);
| ^^^ value borrowed here after move
| (ここでムーブ後に借用されます)
|
= note: this error originates in the macro `$crate::format_args_nl` which comes from the expansion of the macro `println` (in Nightly builds, run with -Z macro-backtrace for more info)
help: consider cloning the value if the performance cost is acceptable
(ヘルプ: パフォーマンスコストが許容できる場合は、クローンすることを検討してください)
|
9 | tx.send(val.clone()).unwrap();
| ++++++++
For more information about this error, try `rustc --explain E0382`.
error: could not compile `message-passing` (bin "message-passing") due to 1 previous error
- 内部の値は
sendしたらrcev側にmoveするって話だな
まとめ
#- 認識ズレてないか怪しかったが思ったよりそのままだった
- マイクロサービスってこういう感じを想定しているんだな
- これで送れる値って
<T>かな
pub fn channel<T>() -> (Sender<T>, Receiver<T>)
- さすがにそうだな
- 今回は自分の中途半端な知識が合っているかの認識合わせだった
- 次はこの辺から
NO IMAGEメッセージ受け渡しを使ってスレッド間でデータを転送する - The Rust Programming Language 日本語版