一道gg多线程面试题求讨论

maybe

实现 void Schedule(int64 timestamp, function* to_run) = 0;多个模块会调用这个function*， 如何实现。   

群里看到的题目，大概做法应该是：
一个min heap，key是timestamp，value是thread
: Q% y. T( |: S- n5 Y# K* K! @! q一个hash table，key是thread id，value是对应thread在min heap中的entry，方便随时添加或kill
4 g) S! c1 G! y& m: ~, [: w
0 x0 S' [4 U1 o" k9 a4 y然后就是一个listener thread的了。。。到点就wake up根据min heap最小的time 跟 curtime 比看是否要执行该function。。。当然follow up可以提一下加锁之类的。。。

那么问题来了。。。。这种一个listener thread加一群working thread的程序该怎么写。。。有人能大概写个轮廓么。。。c++或java都行。。。实在不知道怎么下手。。。求大神帮忙- -


, n7 i: N# G3 C

tcq199055

这题用下线程安全的priority queue就行了吧 价格wrapper class 我大致写了下框架 欢迎讨论
class mythread {
        int time;
3 Y& l" \$ L! r. i1 p2 O- V        Thread t;
; W$ h  v* s! @
: d7 m! G1 H0 b( ]/ C1 F        public mythread(int time, Thread t) {
                this.t = t;
) N7 u5 g& y, [                this.time = time;
! Z5 I& M7 `# P& M# z% E) Y7 w* E        }
! ]9 b0 _$ }. \+ L+ _/ m$ e) E}
9 V2 ?1 |1 f! I! x
1 z) U8 R8 l& Y" Z6 V0 |- y- Npublic class multi_thread {
        PriorityBlockingQueue<mythread> queue = new PriorityBlockingQueue<mythread>(100,
                        new Comparator<mythread>() {
                                @Override
                                public int compare(mythread o1, mythread o2) {
                                        if (o1.time < o2.time)
                                                return -1;
' E" X+ b, M: \* ^' f0 A4 h& o  o                                        else if (o1.time > o2.time)
                                                return 1;
% v* [9 U* O# v! F- T; E                                        // TODO Auto-generated method stub
                                        return 0;
                                }
9 x8 O; B8 W$ w. f" D3 X0 R- h
- Z9 E" `  ~: e6 X' t  I' n6 d                        });

0 {$ \  v' @4 G- w2 D2 f        public Thread pop() {
( w" x# b3 k3 @; j' A9 m$ R                return queue.poll().t;
) N& H0 J% o8 w+ `* A        }
" r& ]: f' h0 ]2 _
        public void add(int time, Thread t) {
                mythread newthread = new mythread(time, t);
                queue.add(newthread);
2 S8 V9 C- J3 {  |0 T  l        }
) A5 W. T3 z  y}

freshwind

有人写个c++的版本吗？ 不会多线程啊...