Secondo la Rust exercise docs, la loro attuazione mutex a base del problema Possibilità Filosofi evita deadlock selezionando sempre forcella ID basso in quanto la sospensione fianco di ogni filosofo, cioè, facendo mancini:Perché i filosofi della ristorazione non si esercitano nella situazione di stallo se vengono eseguiti in modo errato?
let philosophers = vec![
Philosopher::new("Judith Butler", 0, 1),
Philosopher::new("Gilles Deleuze", 1, 2),
Philosopher::new("Karl Marx", 2, 3),
Philosopher::new("Emma Goldman", 3, 4),
Philosopher::new("Michel Foucault", 0, 4),
];
Tuttavia, se disobbedisco a questa regola e cambio gli indici delle forcelle nell'ultimo Philosopher
, il programma viene comunque eseguito senza deadlocking o panico.
Altre cose che ho provato:
- Allungando l'argomento dormono nella
eat()
funzione di chiamata - Commentando l'argomento sonno
- avvolgimento del corpo principale in un
loop{}
per vedere se sarebbe accaduto alla fine
Cosa devo fare per rompere correttamente?
Qui è la fonte completa senza nessuna delle modifiche di cui sopra:
use std::thread;
use std::sync::{Mutex, Arc};
struct Philosopher {
name: String,
left: usize,
right: usize,
}
impl Philosopher {
fn new(name: &str, left: usize, right: usize) -> Philosopher {
Philosopher {
name: name.to_string(),
left: left,
right: right,
}
}
fn eat(&self, table: &Table) {
let _left = table.forks[self.left].lock().unwrap();
let _right = table.forks[self.right].lock().unwrap();
println!("{} is eating.", self.name);
thread::sleep_ms(1000);
println!("{} is done eating.", self.name);
}
}
struct Table {
forks: Vec<Mutex<()>>,
}
fn main() {
let table = Arc::new(Table { forks: vec![
Mutex::new(()),
Mutex::new(()),
Mutex::new(()),
Mutex::new(()),
Mutex::new(()),
]});
let philosophers = vec![
Philosopher::new("Judith Butler", 0, 1),
Philosopher::new("Gilles Deleuze", 1, 2),
Philosopher::new("Karl Marx", 2, 3),
Philosopher::new("Emma Goldman", 3, 4),
Philosopher::new("Michel Foucault", 0, 4),
];
let handles: Vec<_> = philosophers.into_iter().map(|p| {
let table = table.clone();
thread::spawn(move || {
p.eat(&table);
})
}).collect();
for h in handles {
h.join().unwrap();
}
}
PS: Purtroppo l'attuale documentazione ruggine non comprendono questo esempio, in modo che il link qui sopra è rotto.
Meraviglioso. Questo si blocca subito e l'inversione degli indici impedisce definitivamente che si verifichi una situazione di stallo. –
Brillante e semplice. Questo dovrebbe essere copiato nella documentazione – tafia