Lettura due iteratori bloccanti

Question

Sto utilizzando la ruggine websocket library di parlare con le cose e ho questa discussione che sembra più o meno in questo modo:

thread::spawn(move || { 
    while let Ok(Message::Text(text)) = receiver.recv_message() { 
     /* Do some stuff */ 
    } 
}); 

Il ricevitore di cui sopra può anche essere un iteratore blocco:

thread::spawn(move || { 
    for message in receiver.incoming_messages() { 
     /* Do same stuff */ 
    } 
}); 

Voglio inviare un segnale a questo thread dicendogli di smettere di fare le cose. Ho pensato che un mpsc::channel sarebbe ottimo per questo invio di segnali. select! sembrava la strada da percorrere, ma funziona solo se tutti i canali sono tipi mpsc::channel.

C'è qualcosa che può unire due iteratori di blocco e fornire l'output mentre i dati arrivano? O qualsiasi altra soluzione a questo problema? Mi piacerebbe evitare di creare un thread per ciascuna fonte di input e gestire la mia coda.

Answer 1

C'è qualcosa che può unire due iteratori di blocco e fornire l'output mentre i dati arrivano? O qualsiasi altra soluzione a questo problema?

Anche se spero che qualcuno mi smentisca, penso che la risposta debba essere "no". Per definizione, qualcosa che blocca impedirà l'esecuzione di ulteriori lavori su quel thread. Avresti bisogno di qualcosa che possa distinguere tra gli stati di "fatto", "niente da leggere" e "qualcosa da leggere" e che non può essere costruito in cima a blocchi che danno solo due di questi stati.

Vorrei evitare di creare un thread per ciascuna fonte di input e gestire la mia coda.

Non vedo alcun modo per aggirare questo. Poiché un iteratore di blocco blocca il thread, la presenza di più thread consente di aggiungere lo stato di "nothing to read".

La soluzione migliore implicherebbe che entrambe le sorgenti di input abbiano tutti e 3 gli stati.

loop { 
    if let Ok(Message::Text(text)) = receiver.recv_message() { 
     // Do some stuff 
    } else if let Err(TryRecvError::Disconnected) = kill.try_recv() { 
     break; 
    } else { 
     // Something intelligent for the other cases? 
    } 
}