์ฑ„๋„

๋Ÿฌ์ŠคํŠธ์˜ ์ฑ„๋„์€ Sender<T> ์™€ Receiver<T> ๋‘ ๋ถ€๋ถ„์œผ๋กœ ๊ตฌ์„ฑ๋ฉ๋‹ˆ๋‹ค. ์ด ๋‘˜์€ ์ฑ„๋„์„ ํ†ตํ•ด ์„œ๋กœ ์—ฐ๊ฒฐ๋˜์–ด ์žˆ์ง€๋งŒ, ์šฐ๋ฆฌ๋Š” ์ฑ„๋„์„ ๋ณผ ์ˆ˜๋Š” ์—†๊ณ  ์ด ์–‘ ๋๋‹จ๋งŒ์„ ์‚ฌ์šฉํ•˜๊ฒŒ ๋ฉ๋‹ˆ๋‹ค.

use std::sync::mpsc;

fn main() {
    let (tx, rx) = mpsc::channel();

    tx.send(10).unwrap();
    tx.send(20).unwrap();

    println!("์ˆ˜์‹ ๋จ: {:?}", rx.recv());
    println!("์ˆ˜์‹ ๋จ: {:?}", rx.recv());

    let tx2 = tx.clone();
    tx2.send(30).unwrap();
    println!("์ˆ˜์‹ ๋จ: {:?}", rx.recv());
}
  • mpsc๋Š” โ€œMulti-Produce, Single-Consumerโ€๋ฅผ ์˜๋ฏธํ•ฉ๋‹ˆ๋‹ค. Sender์™€ SyncSender๋Š” Clone์„ ๊ตฌํ˜„ํ•˜์ง€๋งŒ (์ฆ‰, ์—ฌ๋Ÿฌ๊ฐœ์˜ producer๋ฅผ ๋งŒ๋“ค์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค) Receiver๋Š” Clone์„ ๊ตฌํ˜„ํ•˜์ง€ ์•Š์Šต๋‹ˆ๋‹ค.
  • send()์™€ recv()๋Š” Result๋ฅผ ๋ฐ˜ํ™˜ํ•ฉ๋‹ˆ๋‹ค. ๋งŒ์ผ Err๊ฐ€ ๋ฐ˜ํ™˜๋œ๋‹ค๋ฉด, ์ƒ๋Œ€๋ฐฉ์˜ Sender๋˜๋Š” Receiver๊ฐ€ ์‚ญ์ œ๋˜์—ˆ๊ณ  ์ฑ„๋„์ด ๋‹ซํ˜”๋‹ค๋Š” ๋œป์ž…๋‹ˆ๋‹ค.