我试图按照Rust文档中的示例进行操作。链接中的最终代码:
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();
thread::sleep_ms(150);
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();
}
}
运行此命令将生成以下输出:
Michel Foucault is eating.
Michel Foucault is done eating.
Emma Goldman is eating.
Emma Goldman is done eating.
Karl Marx is eating.
Karl Marx is done eating.
Gilles Deleuze is eating.
Gilles Deleuze is done eating.
Judith Butler is eating.
Judith Butler is done eating.
根据文献记载,哲学家应该能够同时吃饭。预期结果如下所示:
Gilles Deleuze is eating.
Emma Goldman is eating.
Emma Goldman is done eating.
Gilles Deleuze is done eating.
Judith Butler is eating.
Karl Marx is eating.
Judith Butler is done eating.
Michel Foucault is eating.
Karl Marx is done eating.
Michel Foucault is done eating.
不幸的是,无论代码执行的频率有多高,这种情况都不会发生。
我目前正在Windows上使用rustc 1.5.0(3d7cd77e4 2015-12-04)
,但问题也发生在生锈的操场上。你自己试试吧。
对于这个例子,这是一个半常见的问题。程序员倾向于认为线程是“随机的”,因为线程通常有不同的开始时间和运行长度。线程的大多数用法也不会在线程的整个生命周期内锁定共享资源。请记住,线程是确定性的,因为它们是由算法调度的。
在本例中,主线程创建了一大堆线程,并将它们添加到操作系统管理的队列中。最终,主线程被调度程序阻塞或中断。调度程序查看线程队列并询问“第一个”线程是否可以运行。如果它是可运行的,那么它将运行一个时间片或直到它被阻塞。
“第一个”线程由操作系统决定。例如,Linux有多个可调整的调度程序,允许您确定运行哪些线程的优先级。调度程序还可以选择提前或推迟中断线程
如果在线程的最开始添加打印,可以看到线程的开始顺序不同。下面是一个表,根据100次运行,哪个线程首先启动:
| Position | Emma Goldman | Gilles Deleuze | Judith Butler | Karl Marx | Michel Foucault |
|----------+--------------+----------------+---------------+-----------+-----------------|
| 1 | 4 | 9 | 81 | 5 | 1 |
| 2 | 5 | 66 | 9 | 17 | 3 |
| 3 | 19 | 14 | 5 | 49 | 13 |
| 4 | 46 | 9 | 3 | 20 | 22 |
| 5 | 26 | 2 | 2 | 9 | 61 |
如果我正确地做了统计,最常见的开始顺序是:
请注意,这与代码中定义的哲学家序列相匹配!
还要注意的是,算法本身强加了一个顺序。除了一位哲学家外,其他哲学家都先拿起左手的叉子,然后稍等片刻。如果线程按顺序运行,则每个线程依次等待它前面的线程。大多数线程都依赖于位于“左侧”的线程。如果我们画了一张圆桌,每个人都拿着一把左叉子(死锁),然后我们选了一个人给他一把额外的叉子(打破死锁),那么你可以看到会有很多人可以吃饭。
还要记住println!
使用标准输出;必须由互斥锁保护的可变全局资源。因此,打印可能会导致线程被阻塞和重新安排。
我使用的是OSX,这可能解释了我半一致地得到的与您不同的顺序。
由于分叉之间的Hibernate,问题的实现和建议的输出不匹配。
我不确定为什么米歇尔·福柯总是先开始(可能是线程调度的工作方式),但其余的很容易解释。
由于抓取主叉和非手叉之间的停顿(*),分为两个阶段:
第1阶段之后:
现在,请注意,只有Fork 4可用于抓取!
我们在第二阶段有两个案例:
a) 朱迪思抓住了叉子。米歇尔抓住了叉子
从(a)开始:
在情况(a)中,在任何给定的时间只有一个哲学家可以吃饭。
注意:在让米歇尔抓住他的第一个叉子之前,我暂停了他150毫秒,迫使他这样做。
案件(b)更为复杂,因为我们又一次有了一场比赛,这次是艾玛和米歇尔争夺福克4号。我们都是绅士,所以艾玛会先说,米歇尔抓叉4的案例现在命名为(c):
我们在这里观察到非常有限的并发:艾玛先命中,只有当她完成时,我们才有两个并行流,一个是米歇尔,一个是卡尔
注:我强迫米歇尔暂停150毫秒,然后让他拿第二把叉子。
最后,我们有案例(c):
这里再次强调,根本没有并发性。
(*)这实际上并不能保证,但150ms是一个很长的计算机时间,除非机器负载很大,否则它就会发生。
虽然这本书提出的解决方案确实有效(无论在什么情况下都不会出现死锁),但它并没有表现出太多的并发性,因此它更多的是一种生锈的表现,而不是并发性的表现。。。但是,这是铁锈书,而不是并发书!
我不明白为什么Michel的线程被系统地排在playpen的第一位;但这很容易通过让他睡觉来对抗。
今天,我决定尝试解决哲学家吃饭的问题。所以我写下面的代码。但我认为这是不正确的,所以如果有人告诉我这是怎么回事,我会很高兴的。我使用fork作为锁(我只读取它们,因为我不把对它们的访问放在同步块中),我有一个扩展线程的类,它保留了它的两个锁。 我认为有些不对劲,因为第五位哲学家从不吃饭,第四位和第三位哲学家大多吃饭。提前感谢。
我的Java代码中有一个问题,它应该模拟pholosophers问题,如下所述:http://en.wikipedia.org/wiki/Dining_philosophers_problem我想输出所有哲学家的当前状态,每次他们中的一个吃饭或思考。输出应该是这样的:“OxOx(2)”,其中“X”表示哲学家在吃,“O”表示他在思考,“O”表示他在等筷子。括号中的数字表示状态已更改的哲学家的编号。我
本文向大家介绍餐饮哲学家问题(DPP),包括了餐饮哲学家问题(DPP)的使用技巧和注意事项,需要的朋友参考一下 餐饮哲学家的问题指出,有5位哲学家共享一张圆桌,他们交替吃饭和思考。每个哲学家都有一碗饭和5根筷子。哲学家需要左右筷子才能吃饭。饿了的哲学家只有在两把筷子都齐备的情况下才可以吃东西,否则哲学家放下筷子,重新开始思考。 餐饮哲学家是一个经典的同步问题,因为它演示了一大类并发控制问题。 餐饮
我想用java信号量解决用餐哲学家的问题,但我被卡住了。最高ID的筷子应该是可用的,但它似乎总是采取,我不知道为什么。谁能告诉我我错在哪里了? Fork类: 哲学家班: 主要内容:
我必须用信号量来解决这个问题。在我的代码中,每一个哲学家都在拿一根筷子,其他人都在等待。 我在主函数中仍然有一些错误。你能告诉我怎么使用筷子吗?我是BACI的初学者。
生产者/消费者和读者/作家很容易想到,但是餐饮哲学家呢?在什么样的情况下,N个进程和N个资源会躺在环形拓扑上并相互交错?我可以想到N个进程竞争M个资源,但是在这种情况下,每个进程可以使用任何两个资源。 维基说Dijkstra用它来模拟竞争磁带驱动器外围设备的计算机。这种情况在现代还存在吗?