[面试经验]请教Dropbox onsite题 setTimeout实现

请教Dropbox onsite题  setTimeout实现。楼主最近在看丢盒子的面经，有好几个帖子都提到了setTimeout的实现， 我整理了一下这道题的要求：

• 写一个算法来实现callback + timeout, 要先发现penalty 然后再写一个算法去分配谁先执行，涉及到 n
  您好！
  本帖隐藏的内容需要积分高于 188 才可浏览
  您当前积分为 0。
  使用VIP即刻解锁阅读权限或查看其他获取积分的方式

  游客，您好！
  本帖隐藏的内容需要积分高于 188 才可浏览
  您当前积分为 0。
  VIP即刻解锁阅读权限 或 查看其他获取积分的方式
  Unlock interview details and practice with AI
  Curated Interview Questions from Top Companies
  
  利
  

下周要Onsite了，这道题研究了很久还是没明白具体要做什么，要写成什么样的。请问地里有没有java选手做过这个题或者懂这个题的，麻烦指点一下该怎么做
每条回复都会加米！谢谢大家！

这个可能有帮助
https://www.jianshu.com/p/a8c1458998aa

lz 有联系方式吗 一起讨论

check out this one.
https://gist.github.com/yohhoy/6da797689e16f6fe880c84f41f788c66

qingli.tamu 发表于 2019-4-18 12:29
check out this one.
https://gist.github.com/yohhoy/6da797689e16f6fe880c84f41f788c66

感谢！最近各种找资料，目前来看应该就是delay queue的实现。

1. import threading
   
2. import time
   
3. import heapq
   
4. 
   
5. class photos:
   
6.     def __init__(self):
   
7.         self.q = []
   
8.         self.lock = threading.Lock()
   
9.         self.condition = threading.Condition(self.lock)
   
10. 
    
11.     def put(self, delaytime, val):
    
12.         self.condition.acquire()
    
13.         print('start', threading.current_thread().name)
    
14.         time.sleep(1)
    
15.         heapq.heappush(self.q, (delaytime, val))
    
16.         self.condition.release()
    
17. 
    
18. 
    
19.     def get(self, cb, expire_time):
    
20.         self.condition.acquire()
    
21.         print('get start', threading.current_thread().name)
    
22.         while True:
    
23.             exec_time, val = self.q[0]
    
24.             while time.time() < exec_time and time.time() < expire_time:
    
25.                 time.sleep(3)
    
26. 
    
27.             if exec_time > expire_time:
    
28.                 print('waiting for too long', exec_time)
    
29.                 return
    
30. 
    
31.             self.q.pop(0)
    
32.             cb(exec_time, val)
    
33.             return val
    
34. 
    
35. 
    
36.     def callback(self, exec_time, val):
    
37.         print(val, 'is executed at', time.time(), 'target', exec_time)
    
38. 
    
39. 
    
40. p = photos()
    
41. e_time = time.time() + 100
    
42. expire_time = time.time() + 10
    
43. print(e_time,'e_time')
    
44. f1 = threading.Thread(target=p.put, args=[e_time, 31])
    
45. f2 = threading.Thread(target=p.get, args=[p.callback, expire_time])
    
46. 
    
47. for f in (f1, f2):
    
48.     f.setDaemon(True)
    
49.     f.start()
    
50. 
    
51. for f in (f1, f2):
    
52.     f.join()
    
53. 
    
54. print('complete')

复制代码

我大概用q实现了一下 delay queue和call back, 以及time out. 同请教我的理解是不是对的

mdyuki1016 发表于 2019-4-19 11:51
这个可能有帮助
https://www.jianshu.com/p/a8c1458998aa

忽略 紫薯自护

You will need to use promise and future in multi-threaded programming