求问：Two Sigma那道print timestamps in two blocking queue with diff < 1的题！

如题：Two Sigma那道print timestamps in two blocking queue with diff < 1的题，看了这位大神的解释还是不太懂，如果不加锁会造成什么问题呢？还有如果有C++的代码写法就更好啦

您好！
本帖隐藏的内容需要积分高于 188 才可浏览
您当前积分为 0。
使用VIP即刻解锁阅读权限或查看其他获取积分的方式

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

觉这题板上都没有解释很清楚的，有没有哪位可以详细解释一下。。c++加锁和thread是用boost吗...a

楼主几号onsite?

感谢分享，请问楼主offer了吗，我下周onsite。

jiaozhu200601 发表于 2016-9-12 05:36
感谢分享，请问楼主offer了吗，我下周onsite。

没有，撑到下午还是挂了

ivanml 发表于 2016-9-12 06:58
没有，撑到下午还是挂了

请问有遇到什么新题目吗，如果没有，那么还只是遇到那两套老题的其中一套？

jiaozhu200601 发表于 2016-9-12 09:11
请问有遇到什么新题目吗，如果没有，那么还只是遇到那两套老题的其中一套？

就是老题，但是有随机的follow up
Good luck

lz是用C++上机的吗？lock怎么写的？

楼主搞懂题意了吗...同没有读懂题意，为什么需要加锁？他是指两个queue会实时有新的timestamp进来吗

Sorry if this is a duplicate. I wanted to edit my reply but the website just swallowed my answer. What a f* great user experience.

1. # PCQueue is a thread-safe, unbounded queue.
   
2. # - push() appends an item to the end of the queue
   
3. # - poll() polls an item from the head of the queue. It can block waiting.
   
4. #
   
5. # Queue is not thread safe
   
6. 
   
7. # input source 1
   
8. q1 = PCQueue()
   
9. # input source 2
   
10. q2 = PCQueue()
    
11. # we unify the two streams here
    
12. unified = PCQueue()
    
13. # helper queues
    
14. qs = [Queue(), Queue()]
    
15. 
    
16. 
    
17. def thread1():
    
18.   while True:
    
19.     head = q1.poll()
    
20.     unified.push((head, 1))
    
21. 
    
22. def thread2():
    
23.   while True:
    
24.     head = q2.poll()
    
25.     unified.push((head, 2))
    
26. 
    
27. 
    
28. def processing_thread():
    
29.   while True:
    
30.     val, qid = unified.poll()
    
31. 
    
32.     myq = qs[qid]
    
33.     myq.append(val)
    
34.     # the other queue
    
35.     oq = qs[2 - qid]
    
36. 
    
37.     oq_new_begin = 0
    
38.     for i in xrange(len(oq)):
    
39.       oval = oq[i]
    
40.       diff = oval - val
    
41.       if diff < -1:
    
42.         oq_new_begin = i + 1
    
43.       elif diff > 1:
    
44.         break
    
45.       else if diff != 0 or qid == 1:
    
46.         print oval, val
    
47.     del oq[:oq_new_begin]
    
48. 
    
49. if __name__ == '__main__':
    
50.   t1 = Thread(thread1)
    
51.   t2 = Thread(thread2)
    
52.   t3 = Thread(processing_thread)
    
53. 
    
54.   t1.start()
    
55.   t2.start()
    
56.   t3.start()

复制代码