Закрытие канала, как в Go

Question

Есть ли у ржавчины способ «закрытия» канала, similar to what is available in Go?

Идея состоит в том, чтобы перебирать канал (получать непрерывно), пока канал не покажет, что он не даст никаких значений.

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

Канал закрыт, когда все отправители упали. В вашем коде вы клонируете и даете по одному в каждом потоке, они падают, как они должны, когда заканчиваются нити. Последний отправитель находится в основном потоке, и вы должны отбросить его, как только будут созданы все потоки: drop(tx).

Наконец, самый простой способ получить это, послеdrop(tx).

for elt in rx { 
    /* */ 
} 

Этот цикл заканчивается, когда канал закрыт.