哲学家就餐问题

kedobi

引入服务生解法之后只有偶数项的进程能够拿到两个叉子

有办法能让奇数进程也能拿到叉子吗

1. # -*- coding:utf-8 -*-
   
2. import threading
   
3. from time import sleep
   
4. 
   
5. 
   
6. numPhilosophers = numForks = 10
   
7. 
   
8. class Philosopher(threading.Thread):
   
9.     def __init__(self, index):
   
10.         threading.Thread.__init__(self)
    
11.         self.index = index
    
12.         self.leftFork = forks[self.index]
    
13.         self.rightFork = forks[(self.index + 1) % numForks]
    
14. 
    
15.     def run(self):
    
16.         while True:
    
17.            if waiter.serve(self):
    
18.                self.dining()
    
19.                waiter.clean(self)
    
20.         self.thinking()
    
21. 
    
22.     def dining(self):
    
23.         print ("Philosopher", self.index, " starts to eat.")
    
24.         sleep(1/1000)
    
25.         print ("Philosopher", self.index, " finishes eating and leaves to think.")
    
26.     def thinking(self):
    
27.         sleep(1/100)
    
28. 
    
29. class Fork():
    
30.     def __init__(self, index):
    
31.         self.index = index
    
32.         self._lock = threading.Lock()
    
33. 
    
34.     def pickup(self):
    
35.         self._lock.acquire() #申请锁定进程
    
36. 
    
37.     def putdown(self):
    
38.         self._lock.release() #释放进程
    
39. 
    
40. class Waiter:
    
41.     def __init__(self):
    
42.         self.forks = [Fork(idx) for idx in range(numForks)]
    
43.             #最开始餐叉还没有被分配给任何人，所以全部 False
    
44.         self.forks_using = [False] * numForks
    
45. 
    
46.         #如果哲学家的左右餐叉都是空闲状态，就为这位哲学家服务提供餐叉
    
47.     def serve(self, philor):
    
48.         if not self.forks_using[philor.leftFork.index] and not self.forks_using[philor.rightFork.index]:
    
49.             self.forks_using[philor.leftFork.index] = True
    
50.             self.forks_using[philor.rightFork.index] = True
    
51.             self.forks[philor.leftFork.index].pickup()
    
52.             self.forks[philor.rightFork.index].pickup()
    
53.             return True
    
54.         else:
    
55.             return False        
    
56. 
    
57.         #哲学家用餐完毕后，清理并回收餐叉
    
58.     def clean(self, philor):
    
59.         self.forks[philor.leftFork.index].putdown()
    
60.         self.forks[philor.rightFork.index].putdown()
    
61.         self.forks_using[philor.leftFork.index] = False
    
62.         self.forks_using[philor.rightFork.index] = False
    
63. 
    
64. 
    
65. if __name__ == '__main__':
    
66.         #创建服务生与哲学家实例
    
67.     waiter = Waiter()
    
68.     forks = [Fork(idx) for idx in range(numForks)]
    
69.     philosophers = [Philosopher(idx) for idx in range(numPhilosophers)]
    
70. 
    
71.         #开启所有的哲学家线程
    
72.     for philosopher in philosophers:
    
73.         philosopher.start()
    
74. 
    
75.         # 方便 CTRL + C 退出程序
    
76.     try:
    
77.         while True: sleep(0.1)
    
78.     except Exception:
    
79.         raise e

复制代码

kedobi

运行环境py3.5