Đóng kênh, như ở mục

Question

Rust có cách "đóng" kênh, similar to what is available in Go không?

Ý tưởng là lặp qua kênh (nhận liên tục) cho đến khi kênh cho biết rằng kênh sẽ không tạo thêm bất kỳ giá trị nào.

use std::sync::{Arc, Mutex}; 
use std::thread; 
use std::sync::mpsc; 

fn main() { 
    let data = Arc::new(Mutex::new(0u32)); 
    let (tx, rx) = mpsc::channel::<u32>(); 
    { 
     let (data, tx) = (data.clone(), tx.clone()); 
     thread::spawn(move || { 
      for _ in 0..10 { 
       let mut data = data.lock().unwrap(); 
       *data += 1; 
       tx.send(*data).unwrap(); 
      } 
      // *** How could I close the channel here, to signal the work is done? 
     }); 
    } 

    // *** How can I detect a closed channel here? Pattern matching? 
    for _ in 0..10 { 
     let x = rx.recv().unwrap(); 
     println!("{}", x); 
    } 
} 

Answer 1

Kênh này đóng khi tất cả người gửi đã bỏ. Trong mã của bạn, bạn sao chép và cung cấp một cái cho mỗi luồng, những giọt này sẽ xuất hiện khi chuỗi kết thúc. Người gửi cuối cùng nằm trong chủ đề chính và bạn nên thả nó ngay khi tất cả các chủ đề đã được sinh ra: drop(tx).

Cuối cùng, cách dễ nhất để nhận là số này, saudrop(tx).

for elt in rx { 
    /* */ 
} 

Vòng lặp này kết thúc khi kênh được đóng lại.